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
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
: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
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
>
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
[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-
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
>
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
>>> 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
/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
10 matches
Mail list logo