Jorge created KAFKA-6095: ---------------------------- Summary: Error when displaying LAG information consumer partitions that use zookeeper Key: KAFKA-6095 URL: https://issues.apache.org/jira/browse/KAFKA-6095 Project: Kafka Issue Type: Bug Components: consumer Affects Versions: 0.11.0.1 Environment: java version "1.8.0_144" Reporter: Jorge Priority: Critical
/opt/kafka/bin/kafka-consumer-groups.sh --zookeeper localhost --group logs --describe Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API). [2017-10-20 10:09:01,182] ERROR error parsing consumer json string { "logs": 1 } (kafka.consumer.TopicCount$) kafka.common.KafkaException: error constructing TopicCount : { "logs": 1 } at kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:72) at kafka.utils.ZkUtils$$anonfun$getTopicsPerMemberId$1.apply(ZkUtils.scala:862) at kafka.utils.ZkUtils$$anonfun$getTopicsPerMemberId$1.apply(ZkUtils.scala:861) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) at scala.collection.Iterator$class.foreach(Iterator.scala:891) at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) at scala.collection.AbstractTraversable.map(Traversable.scala:104) at kafka.utils.ZkUtils.getTopicsPerMemberId(ZkUtils.scala:861) at kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService.collectGroupAssignment(ConsumerGroupCommand.scala:281) at kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describeGroup(ConsumerGroupCommand.scala:171) at kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:235) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:74) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Error: Executing consumer group command failed due to error constructing TopicCount : { "logs": 1 } -- This message was sent by Atlassian JIRA (v6.4.14#64029)