You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2015/11/10 23:45:15 UTC
kafka git commit: KAFKA-2793: Use ByteArrayDeserializer instead of
StringDeserializer for keys in ConsoleConsumer with new consumer.
Repository: kafka
Updated Branches:
refs/heads/trunk 60c06734b -> 64a1bfeb9
KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Gwen Shapira
Closes #482 from ewencp/kafka-2793-console-consumer-new-consumer-deserializer
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/64a1bfeb
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/64a1bfeb
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/64a1bfeb
Branch: refs/heads/trunk
Commit: 64a1bfeb9b1b90c94cc62ee2587f9745c850ada3
Parents: 60c0673
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Authored: Tue Nov 10 14:43:25 2015 -0800
Committer: Gwen Shapira <cs...@gmail.com>
Committed: Tue Nov 10 14:43:25 2015 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/tools/ConsoleConsumer.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/64a1bfeb/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/ConsoleConsumer.scala b/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
index 2b1a69a..0dedcd9 100755
--- a/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
+++ b/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
@@ -162,7 +162,7 @@ object ConsoleConsumer extends Logging {
props.putAll(config.consumerProps)
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, if (config.options.has(config.resetBeginningOpt)) "earliest" else "latest")
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, config.bootstrapServer)
- props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, if (config.keyDeserializer != null) config.keyDeserializer else "org.apache.kafka.common.serialization.StringDeserializer")
+ props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, if (config.keyDeserializer != null) config.keyDeserializer else "org.apache.kafka.common.serialization.ByteArrayDeserializer")
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, if (config.valueDeserializer != null) config.valueDeserializer else "org.apache.kafka.common.serialization.ByteArrayDeserializer")
props