From d913d17b58e2d9fb18ab5954b69280e8504840ff Mon Sep 17 00:00:00 2001 From: Gwen Shapira Date: Thu, 18 Dec 2014 11:07:59 -0800 Subject: [PATCH] KAFKA-1824 - fix ConsoleProducer so parse.key and key.separator will work again --- core/src/main/scala/kafka/tools/ConsoleProducer.scala | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/core/src/main/scala/kafka/tools/ConsoleProducer.scala b/core/src/main/scala/kafka/tools/ConsoleProducer.scala index 1061cc7..e011e42 100644 --- a/core/src/main/scala/kafka/tools/ConsoleProducer.scala +++ b/core/src/main/scala/kafka/tools/ConsoleProducer.scala @@ -36,10 +36,8 @@ object ConsoleProducer { val reader = Class.forName(config.readerClass).newInstance().asInstanceOf[MessageReader] val props = new Properties props.putAll(config.cmdLineProps) - - val readerProps = new Properties(props) - readerProps.put("topic", config.topic) - reader.init(System.in, readerProps) + props.put("topic", config.topic) + reader.init(System.in, props) try { val producer = -- 1.9.3 (Apple Git-50)