kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2121 Follow-up: minor bug fix as pointed out by Sean Lydon
Date Tue, 28 Apr 2015 00:41:54 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk dbfe8c0a7 -> 97358411a


KAFKA-2121 Follow-up: minor bug fix as pointed out by Sean Lydon


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

Branch: refs/heads/trunk
Commit: 97358411af15b64a4bc21c58a0e477fbe9c9b79d
Parents: dbfe8c0
Author: Guozhang Wang <wangguoz@gmail.com>
Authored: Mon Apr 27 17:41:43 2015 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Mon Apr 27 17:41:43 2015 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/97358411/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
index 09ecb42..d301be4 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
@@ -495,7 +495,7 @@ public class KafkaConsumer<K, V> implements Consumer<K, V>
{
             if (keyDeserializer == null) {
                 this.keyDeserializer = config.getConfiguredInstance(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
                         Deserializer.class);
-                this.keyDeserializer.configure(config.originals(), false);
+                this.keyDeserializer.configure(config.originals(), true);
             } else {
                 this.keyDeserializer = keyDeserializer;
             }


Mime
View raw message