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, 陈小军 <chenxiao...@nhn.com> 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 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,10.96.250.216:10013,10.96.250.217:10013/nelo2-kafka
>
> Topic:nelo2-normal-logs PartitionCount:3 ReplicationFactor:2
> Configs:
> Topic: nelo2-normal-logs Partition: 0 Leader: 3
> Replicas: 3,0 Isr: 0,3
> Topic: nelo2-normal-logs Partition: 1 Leader: 0
> Replicas: 0,1 Isr: 0,1
> Topic: nelo2-normal-logs Partition: 2 Leader: 1
> Replicas: 1,3 Isr: 1,3
>
> but when I use some sdk to get the meta info from broker, the isr is
> different.
> metadata: { size: 246,
> correlationId: 0,
> brokerNum: -1,
> nodeId: 1,
> host: 'xseed171.kdev.nhnsystem.com',
> port: 9093,
> topicNum: 0,
> topicError: 0,
> topic: 'nelo2-normal-logs',
> partitionNum: 2,
> errorCode: 0,
> partition: 0,
> leader: 3,
> replicasNum: 2,
> replicas: [ 3, 0 ],
> isrNum: 2,
> isr: [ 0, 3 ] }
> metadata: { size: 246,
> correlationId: 0,
> brokerNum: -1,
> nodeId: 1,
> host: 'xseed171.kdev.nhnsystem.com',
> port: 9093,
> topicNum: 0,
> topicError: 0,
> topic: 'nelo2-normal-logs',
> partitionNum: 1,
> errorCode: 0,
> partition: 1,
> leader: 0,
> replicasNum: 2,
> replicas: [ 0, 1 ],
> isrNum: 2,
> isr: [ 0, 1 ] }
> metadata: { size: 246,
> correlationId: 0,
> brokerNum: -1,
> nodeId: 1,
> host: 'xseed171.kdev.nhnsystem.com',
> port: 9093,
> topicNum: 0,
> topicError: 0,
> topic: 'nelo2-normal-logs',
> partitionNum: 0,
> errorCode: 0,
> partition: 2,
> leader: 1,
> replicasNum: 2,
> replicas: [ 1, 3 ],
> isrNum: 1,
> isr: [ 1 ] }
>
> I also use other sdk, get the same result. I check the logs from kafka,
> it seems the sdk result is right. the tool get the wrong result. why is it
> happend?
>
> [2014-04-24 14:53:57,705] TRACE Broker 3 cached leader info
> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:7,ControllerEpoch:9),ReplicationFactor:2),AllReplicas:0,1)
> for partition [nelo2-normal-logs,1] in response to UpdateMetadata request
> sent by controller 0 epoch 10 with correlation id 13 (state.change.logger)
> [2014-04-24 14:53:57,705] TRACE Broker 3 cached leader info
> (LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:9,ControllerEpoch:10),ReplicationFactor:2),AllReplicas:1,3)
> for partition [nelo2-normal-logs,2] in response to UpdateMetadata request
> sent by controller 0 epoch 10 with correlation id 13 (state.change.logger)
> [2014-04-24 14:53:57,705] TRACE Broker 3 cached leader info
> (LeaderAndIsrInfo:(Leader:3,ISR:0,3,LeaderEpoch:10,ControllerEpoch:10),ReplicationFactor:2),AllReplicas:3,0)
> for partition [nelo2-normal-logs,0] in response to UpdateMetadata request
> sent by controller 0 epoch 10 with correlation id 13 (state.change.logger)
>
> Thanks~!
>
> Best Regards
> Jerry
>
