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 <jun...@gmail.com> Authored: Mon Jan 19 15:53:53 2015 -0800 Committer: Jun Rao <jun...@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 =