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-3952: Consumer rebalance verifier never succeed due to type mismatch
Date Fri, 15 Jul 2016 17:09:02 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 78bd89786 -> dfd5946d8


KAFKA-3952: Consumer rebalance verifier never succeed due to type mismatch

Author: Wan Wenli <wwl.990@hotmail.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #1612 from swwl1992/ticket-KAFKA-3952-fix-consumer-rebalance-verifier

(cherry picked from commit 7a70c1a1087ca78d5e6db3908f6d6b6b19e8aaab)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


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

Branch: refs/heads/0.10.0
Commit: dfd5946d885d7c9ee796a013672dab16e3ccb7d3
Parents: 78bd897
Author: Wan Wenli <wwl.990@hotmail.com>
Authored: Fri Jul 15 10:08:48 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Jul 15 10:08:58 2016 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/dfd5946d/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala b/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala
index 3077896..b9590f8 100644
--- a/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala
+++ b/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala
@@ -18,7 +18,6 @@
 package kafka.tools
 
 import joptsimple.OptionParser
-import org.I0Itec.zkclient.ZkClient
 import org.apache.kafka.common.security._
 
 import kafka.utils.{Logging, ZKGroupTopicDirs, ZkUtils, CommandLineUtils}
@@ -117,7 +116,7 @@ object VerifyConsumerRebalance extends Logging {
           // check if the owner is a valid consumer id
           consumerIdsForTopic match {
             case Some(consumerIds) =>
-              if(!consumerIds.contains(partitionOwner)) {
+              if(!consumerIds.map(c => c.toString).contains(partitionOwner)) {
                 error(("Owner %s for partition [%s,%d] is not a valid member of consumer
" +
                   "group %s").format(partitionOwner, topic, partition, group))
                 rebalanceSucceeded = false


Mime
View raw message