[
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)
