kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject kafka git commit: KAFKA-1824 - fix ConsoleProducer so parse.key and key.separator will work again; reviewed by Neha Narkhede
Date Fri, 19 Dec 2014 01:06:02 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 92d1d4cd3 -> 84521872d


KAFKA-1824 - fix ConsoleProducer so parse.key and key.separator will work again; reviewed
by Neha Narkhede


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/84521872
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/84521872
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/84521872

Branch: refs/heads/trunk
Commit: 84521872d18dd90aff6eb47d470893f64749783f
Parents: 92d1d4c
Author: Gwen Shapira <cshapi@gmail.com>
Authored: Thu Dec 18 17:05:02 2014 -0800
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Thu Dec 18 17:05:55 2014 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/ConsoleProducer.scala | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/84521872/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 1061cc7..ac85949 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 =
@@ -134,13 +132,13 @@ object ConsoleProducer {
       .ofType(classOf[java.lang.Integer])
       .defaultsTo(100)
     val sendTimeoutOpt = parser.accepts("timeout", "If set and the producer is running in
asynchronous mode, this gives the maximum amount of time" +
-      " a message will queue awaiting suffient batch size. The value is given in ms.")
+      " a message will queue awaiting sufficient batch size. The value is given in ms.")
       .withRequiredArg
       .describedAs("timeout_ms")
       .ofType(classOf[java.lang.Integer])
       .defaultsTo(1000)
     val queueSizeOpt = parser.accepts("queue-size", "If set and the producer is running in
asynchronous mode, this gives the maximum amount of " +
-      " messages will queue awaiting suffient batch size.")
+      " messages will queue awaiting sufficient batch size.")
       .withRequiredArg
       .describedAs("queue_size")
       .ofType(classOf[java.lang.Integer])


Mime
View raw message