Hi, We upgraded to 0.8.1 version of Kafka in TEST,we did load test shutting down 1 broker in the cluster,we are getting below error and cluster becomes unresponsive.
Do you guys have any fix for this issue ?. [2014-04-11 15:10:42.595-0600] ERROR Conditional update of path /brokers/topics/rain-load-test/partitions/52/state with data {"controller_epoch":33,"leader":1,"version":1,"leader_epoch":32,"isr":[1]} and expected version 55 failed due to org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode = BadVersion for /brokers/topics/rain-load-test/partitions/52/state (kafka.utils.ZkUtils$) [2014-04-11 15:10:42.595-0600] INFO Partition [rain-load-test,52] on broker 1: Cached zkVersion [55] not equal to that in zookeeper, skip updating ISR (kafka.cluster.Partition) Thanks, Balaji