Renamed Consumer to StreamConsumer to avoid ambiguity.