You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jorge (JIRA)" <ji...@apache.org> on 2017/10/20 11:00:00 UTC
[jira] [Created] (KAFKA-6095) Error when displaying LAG information
consumer partitions that use zookeeper
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)