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)

Reply via email to