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 <m...@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 <m...@ewencp.org> Authored: Tue Nov 10 14:43:25 2015 -0800 Committer: Gwen Shapira <csh...@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
