kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-807; LineMessageReader doesn't correctly parse the key separator; patched by Dragos Manolescu; reviewed by Jun Rao
Date Fri, 29 Mar 2013 15:33:22 GMT
Updated Branches:
  refs/heads/0.8 9f6af315c -> 68528dafa


kafka-807; LineMessageReader doesn't correctly parse the key separator; patched by Dragos
Manolescu; 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/68528daf
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/68528daf
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/68528daf

Branch: refs/heads/0.8
Commit: 68528dafa1fcfb7a469654575288e19f5b4bda04
Parents: 9f6af31
Author: Dragos Manolescu <dam@micro-workflow.com>
Authored: Fri Mar 29 08:28:35 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Fri Mar 29 08:31:50 2013 -0700

----------------------------------------------------------------------
 .../scala/kafka/producer/ConsoleProducer.scala     |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/68528daf/core/src/main/scala/kafka/producer/ConsoleProducer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/producer/ConsoleProducer.scala b/core/src/main/scala/kafka/producer/ConsoleProducer.scala
index eebfda6..9c2260b 100644
--- a/core/src/main/scala/kafka/producer/ConsoleProducer.scala
+++ b/core/src/main/scala/kafka/producer/ConsoleProducer.scala
@@ -196,7 +196,7 @@ object ConsoleProducer {
       topic = props.getProperty("topic")
       if(props.containsKey("parse.key"))
         parseKey = props.getProperty("parse.key").trim.toLowerCase.equals("true")
-      if(props.containsKey("key.seperator"))
+      if(props.containsKey("key.separator"))
         keySeparator = props.getProperty("key.separator")
       if(props.containsKey("ignore.error"))
         ignoreError = props.getProperty("ignore.error").trim.toLowerCase.equals("true")


Mime
View raw message