kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Arunkumar Srambikkal (asrambik)" <asram...@cisco.com>
Subject JSON parsing causing rebalance to fail
Date Wed, 04 Mar 2015 11:56:40 GMT
Hi,

When I start a new consumer, it throws a Rebalance exception.

However I hit it only on some machines where the run time libraries are different

The stack given below is what I encounter - is this a known issue?

I saw this Jira but it's not resolved  so thought to confirm - https://issues.apache.org/jira/browse/KAFKA-1405

Thanks
Arun

[2015-03-04 14:30:37,609] INFO [name], exception during rebalance  (kafka.consumer.ZookeeperConsumerConnector)

kafka.common.KafkaException: Failed to parse the broker info from zookeeper: {"jmx_port":-1,"timestamp":"1425459616502","host":"1.1.1.1","version":1,"port":64356}
                at kafka.cluster.Broker$.createBroker(Broker.scala:35)
                ................
Caused by: java.lang.ClassCastException: java.lang.Double cannot be cast to java.lang.Integer
                at scala.runtime.BoxesRunTime.unboxToInt(BoxesRunTime.java:105)
                at kafka.cluster.Broker$.createBroker(Broker.scala:40)


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message