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)