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)