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/trunk Commit: 68528dafa1fcfb7a469654575288e19f5b4bda04 Parents: 9f6af31 Author: Dragos Manolescu <[email protected]> Authored: Fri Mar 29 08:28:35 2013 -0700 Committer: Jun Rao <[email protected]> Committed: Fri Mar 29 08:31:50 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/producer/ConsoleProducer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- 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")
