[ https://issues.apache.org/jira/browse/KAFKA-6095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Manikumar resolved KAFKA-6095. ------------------------------ Resolution: Auto Closed Closing as scala consumer related code/tools are removed from 2.0 release. looks like above issue is related to third party client behaviour against 0.11.0.1 broker version. Pls raise the issue with the client project. > 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: Minor > > /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 (v7.6.3#76005)