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 2015/01/20 01:20:35 UTC
kafka git commit: Revert "kafka-1711;
WARN Property topic is not valid when running console producer;
patched by Joe Crobak; reviewed by Jun Rao"
Repository: kafka
Updated Branches:
refs/heads/0.8.2 059b09dec -> 0b312a6b9
Revert "kafka-1711; WARN Property topic is not valid when running console producer; patched by Joe Crobak; reviewed by Jun Rao"
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/0b312a6b
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/0b312a6b
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/0b312a6b
Branch: refs/heads/0.8.2
Commit: 0b312a6b9f0833d38eec434bfff4c647c1814564
Parents: 059b09d
Author: Jun Rao <ju...@gmail.com>
Authored: Mon Jan 19 15:53:53 2015 -0800
Committer: Jun Rao <ju...@gmail.com>
Committed: Mon Jan 19 15:53:53 2015 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/tools/ConsoleProducer.scala | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/0b312a6b/core/src/main/scala/kafka/tools/ConsoleProducer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/ConsoleProducer.scala b/core/src/main/scala/kafka/tools/ConsoleProducer.scala
index 2a8e981..a680b62 100644
--- a/core/src/main/scala/kafka/tools/ConsoleProducer.scala
+++ b/core/src/main/scala/kafka/tools/ConsoleProducer.scala
@@ -35,11 +35,9 @@ object ConsoleProducer {
val config = new ProducerConfig(args)
val reader = Class.forName(config.readerClass).newInstance().asInstanceOf[MessageReader]
val props = new Properties
+ props.put("topic", config.topic)
props.putAll(config.cmdLineProps)
-
- val readerProps = new Properties(props)
- readerProps.put("topic", config.topic)
- reader.init(System.in, readerProps)
+ reader.init(System.in, props)
try {
val producer =