You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2013/01/12 03:26:37 UTC
[6/11] git commit: KAFKA-692 ConsoleConsumer outputs diagnostic
message to stdout instead of stderr; reviewed by Neha Narkhede
KAFKA-692 ConsoleConsumer outputs diagnostic message to stdout instead of stderr; reviewed by Neha Narkhede
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c12608c5
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c12608c5
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c12608c5
Branch: refs/heads/trunk
Commit: c12608c5fed04ece82582cb5b764ceb0b5b389e0
Parents: b71e6dc
Author: Ben Fleis <be...@monkey.org>
Authored: Fri Jan 11 09:55:52 2013 -0800
Committer: Neha Narkhede <ne...@apache.org>
Committed: Fri Jan 11 09:58:04 2013 -0800
----------------------------------------------------------------------
.../scala/kafka/consumer/ConsoleConsumer.scala | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/c12608c5/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala b/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala
index 9378357..b857d14 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()