KAFKA-124 Console consumer does not stop consuming if the program reading from standard out dies. Check for errors on the output stream and exit if no one is listening.
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala