Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Solutions on the web

via Stack Overflow by Alejandro Agapito Bautista
, 1 year ago
error constructing TopicCount : {"version":1,"subscription":{null:1},"pattern":"static","timestamp":"1470866652901"}
kafka.common.KafkaException: error constructing TopicCount : {"version":1,"subscription":{null:1},"pattern":"static","timestamp":"1470866652901"}	at kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:67)	at kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:678)	at kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:677)	at scala.collection.Iterator$class.foreach(Iterator.scala:631)	at scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:474)	at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)	at scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:521)	at kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:677)	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:437)	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:408)	at scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282)	at scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265)	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:402)	at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:722)	at kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:212)	at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:80)	at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:92)	at com.raidentrance.kafka.Consumer.run(Consumer.java:61)