From c12608c5fed04ece82582cb5b764ceb0b5b389e0 Mon Sep 17 00:00:00 2001
From: Ben Fleis <ben@monkey.org>
Date: Fri, 11 Jan 2013 09:55:52 -0800
Subject: [PATCH] KAFKA-692 ConsoleConsumer outputs diagnostic message to
 stdout instead of stderr; reviewed by Neha Narkhede

---
 core/src/main/scala/kafka/consumer/ConsoleConsumer.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala b/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala
index 9378357cab9..b857d145496 100644
--- a/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala
+++ b/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala
@@ -209,7 +209,7 @@ object ConsoleConsumer extends Logging {
     } catch {
       case e => error("Error processing message, stopping consumer: ", e)
     }
-    System.out.println("Consumed %d messages".format(numMessages))
+    System.err.println("Consumed %d messages".format(numMessages))
     System.out.flush()
     formatter.close()
     connector.shutdown()