Browse Source

KAFKA-692 ConsoleConsumer outputs diagnostic message to stdout instead of stderr; reviewed by Neha Narkhede

0.8.0-beta1-candidate1
Ben Fleis 12 years ago committed by Neha Narkhede
parent
commit
c12608c5fe
  1. 2
      core/src/main/scala/kafka/consumer/ConsoleConsumer.scala

2
core/src/main/scala/kafka/consumer/ConsoleConsumer.scala

@ -209,7 +209,7 @@ object ConsoleConsumer extends Logging { @@ -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()

Loading…
Cancel
Save