kafka.common.KafkaException: error constructing TopicCount : {"version":1,"subscription":{null:1},"pattern":"static","timestamp":"1470866652901"}

tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    KafkaException: error constructing TopicCount

    Stack Overflow | 6 months ago | Alejandro Agapito Bautista
    kafka.common.KafkaException: error constructing TopicCount : {"version":1,"subscription":{null:1},"pattern":"static","timestamp":"1470866652901"}

    Root Cause Analysis

    1. kafka.common.KafkaException

      error constructing TopicCount : {"version":1,"subscription":{null:1},"pattern":"static","timestamp":"1470866652901"}

      at kafka.consumer.TopicCount$.constructTopicCount()
    2. Apache Kafka
      ZkUtils$$anonfun$getConsumersPerTopic$1.apply
      1. kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:67)
      2. kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:678)
      3. kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:677)
      3 frames
    3. Scala
      JavaConversions$JListWrapper.foreach
      1. scala.collection.Iterator$class.foreach(Iterator.scala:631)
      2. scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:474)
      3. scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
      4. scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:521)
      4 frames
    4. Apache Kafka
      ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp
      1. kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:677)
      2. kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:437)
      3. kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:408)
      3 frames
    5. Scala
      Range$$anon$2.foreach$mVc$sp
      1. scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282)
      2. scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265)
      2 frames
    6. Apache Kafka
      ZookeeperConsumerConnector.createMessageStreams
      1. kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:402)
      2. kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:722)
      3. kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:212)
      4. kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:80)
      5. kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:92)
      5 frames
    7. com.raidentrance.kafka
      Consumer.run
      1. com.raidentrance.kafka.Consumer.run(Consumer.java:61)
      1 frame