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

  1. 0

    KafkaException: error constructing TopicCount

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

    [jira] [Commented] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

    mail-archive.com | 3 months ago
    kafka.common.KafkaException: Failed to parse the broker info from zookeeper: {"jmx_port":-1,"timestamp":"1442952770627","endpoints":["PLAINTEXT://<host>:<plaintextport>","SSL://<host>:<sslport>"],"host”:”<host>","version":2,"port”:<port>}
  3. 0

    Having to lean druid all over again - how to run coordinator

    Google Groups | 3 years ago | David Montgomery
    kafka.common.KafkaException: Can't parse json string: null
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Kafka consumer Failed to find leader for Set and Fetching topic metadata with correlation id 4 for topics failed

    Stack Overflow | 9 months ago | Oggie
    kafka.common.KafkaException: fetching topic metadata for topics [Set(events)] from broker [ArrayBuffer(id:0,host:prodMessage01-1.blah.com,port:9092)] failed at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    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