question about isr

2014-04-23 Thread 陈小军
Hi Team, I found a strange phenomenon of isr list in my kafka cluster When I use the tool that kafka provide to get the topic information, and it show isr list as following, seem it is ok [irt...@xseed171.kdev bin]$ ./kafka-topics.sh --describe --zookeeper 10.96.250.215:10013,1

Re: question about isr

2014-04-24 Thread Jun Rao
Interesting. Which version of Kafka are you using? Were you doing some partition reassignment? Thanks, Jun On Wed, Apr 23, 2014 at 11:14 PM, 陈小军 wrote: > Hi Team, >I found a strange phenomenon of isr list in my kafka cluster > >When I use the tool that kafka provide to get the topic i

Re: question about isr

2014-04-24 Thread 陈小军
: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.Partit Best Regards Jerry -Original Message- From: "Jun Rao"<jun...@gmail.com> To: "users@kafka.apache.org"<users@k

Re: question about isr

2014-05-11 Thread Jun Rao
gt; [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 >

Re: question about isr

2014-05-11 Thread Ian Friedman
ion [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] f

Re: question about isr

2014-05-12 Thread Ian Friedman
[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-

Re: question about isr

2014-05-12 Thread Jun Rao
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 >

Re: question about isr

2014-05-12 Thread Ian Friedman
rtitions/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] INF

Re: question about isr

2014-05-12 Thread Jun Rao
>>> 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

Re: question about isr

2014-05-15 Thread Ian Friedman
/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.Partit > Best Regards > Jerry &g