kafka git commit: KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer.

[gwenshap]

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 

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 
Authored: Tue Nov 10 14:43:25 2015 -0800
Committer: Gwen Shapira 
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

kafka git commit: KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer.

[gwenshap]

Repository: kafka
Updated Branches:
  refs/heads/0.9.0 501ac0282 -> 75db96e42


KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in 
ConsoleConsumer with new consumer.

Author: Ewen Cheslack-Postava 

Reviewers: Gwen Shapira

Closes #482 from ewencp/kafka-2793-console-consumer-new-consumer-deserializer

(cherry picked from commit 64a1bfeb9b1b90c94cc62ee2587f9745c850ada3)
Signed-off-by: Gwen Shapira 


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

Branch: refs/heads/0.9.0
Commit: 75db96e429de34373b92d8f4f5df508071b05127
Parents: 501ac02
Author: Ewen Cheslack-Postava 
Authored: Tue Nov 10 14:43:25 2015 -0800
Committer: Gwen Shapira 
Committed: Tue Nov 10 14:45:18 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/75db96e4/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 9f296bd..6504925 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