From b3b30a469182c3987780efd6248eed4c762b1160 Mon Sep 17 00:00:00 2001 From: Joe Crobak Date: Sat, 18 Oct 2014 23:05:52 +0000 Subject: [PATCH] KAFKA-1711: fix WARN for console producer. Create a separate Properties instance for initializing the reader, which requires an additional "topic" property that the ProducerConfig generates a WARN about. --- core/src/main/scala/kafka/tools/ConsoleProducer.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/tools/ConsoleProducer.scala b/core/src/main/scala/kafka/tools/ConsoleProducer.scala index 397d80d..1061cc7 100644 --- a/core/src/main/scala/kafka/tools/ConsoleProducer.scala +++ b/core/src/main/scala/kafka/tools/ConsoleProducer.scala @@ -35,9 +35,11 @@ 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) - reader.init(System.in, props) + + val readerProps = new Properties(props) + readerProps.put("topic", config.topic) + reader.init(System.in, readerProps) try { val producer = -- 1.9.3 (Apple Git-50)