Hi all
i use 0.8.1 release to do test, and get following error logs
[hadoop@nelo76 libs]$ [2014-03-14 12:11:44,310] INFO Partition
[nelo2-normal-logs,0] on broker 0: Shrinking ISR for partition
[nelo2-normal-logs,0] from 0,1 to 0 (kafka.cluster.Partition)
[2014-03-14 12:11:44,313] ERROR Conditional update of path
/brokers/topics/nelo2-normal-logs/partitions/0/state with data
{"controller_epoch":4,"leader":0,"version":1,"leader_epoch":5,"isr":[0]} and
expected version 7 failed due to
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode =
BadVersion for /brokers/topics/nelo2-normal-logs/partitions/0/state
(kafka.utils.ZkUtils$)
[2014-03-14 12:11:44,313] INFO Partition [nelo2-normal-logs,0] on broker 0:
Cached zkVersion [7] not equal to that in zookeeper, skip updating ISR
(kafka.cluster.Partition)
[2014-03-14 12:11:44,313] INFO Partition [nelo2-symbolicated-logs,1] on broker
0: Shrinking ISR for partition [nelo2-symbolicated-logs,1] from 0,2 to 0
(kafka.cluster.Partition)
[2014-03-14 12:11:44,315] ERROR Conditional update of path
/brokers/topics/nelo2-symbolicated-logs/partitions/1/state with data
{"controller_epoch":4,"leader":0,"version":1,"leader_epoch":6,"isr":[0]} and
expected version 8 failed due to
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode =
BadVersion for /brokers/topics/nelo2-symbolicated-logs/partitions/1/state
(kafka.utils.ZkUtils$)
[2014-03-14 12:11:44,315] INFO Partition [nelo2-symbolicated-logs,1] on broker
0: Cached zkVersion [8] not equal to that in zookeeper, skip updating ISR
(kafka.cluster.Partition)
[2014-03-14 12:11:44,316] INFO Partition [nelo2-crash-logs,1] on broker 0:
Shrinking ISR for partition [nelo2-crash-logs,1] from 0,1 to 0
(kafka.cluster.Partition)
[2014-03-14 12:11:44,318] ERROR Conditional update of path
/brokers/topics/nelo2-crash-logs/partitions/1/state with data
{"controller_epoch":4,"leader":0,"version":1,"leader_epoch":5,"isr":[0]} and
expected version 7 failed due to
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode =
BadVersion for /brokers/topics/nelo2-crash-logs/partitions/1/state
(kafka.utils.ZkUtils$)
[2014-03-14 12:11:44,318] INFO Partition [nelo2-crash-logs,1] on broker 0:
Cached zkVersion [7] not equal to that in zookeeper, skip updating ISR
(kafka.cluster.Partition)
this issue is related withe zookeeper version?
my zookeeper version is 3.4.3
Best Regards
Jerry
