topic状态变成
Topic:test PartitionCount:10 ReplicationFactor:3 Configs:
Topic: test Partition: 0 Leader: 5 Replicas: 5,1,2 Isr: 1,2,5
Topic: test Partition: 1 Leader: 1 Replicas: 1,2,3 Isr: 3,1,2
Topic: test Partition: 2 Leader: 4 Replicas: 2,3,4 Isr: 4
Topic: test Partition: 3 Leader: 4 Replicas: 3,4,5 Isr: 4
Topic: test Partition: 4 Leader: 4 Replicas: 4,5,1 Isr: 1,5,4
Topic: test Partition: 5 Leader: 5 Replicas: 5,2,3 Isr: 3,2,5
Topic: test Partition: 6 Leader: 4 Replicas: 1,3,4 Isr: 4
Topic: test Partition: 7 Leader: 4 Replicas: 2,4,5 Isr: 4
Topic: test Partition: 8 Leader: 3 Replicas: 3,5,1 Isr: 1,3,5
Topic: test Partition: 9 Leader: 4 Replicas: 4,1,2 Isr: 1,2,4
集群无法消费数据
异常如下:
INFO [Partition topic-xxx-1 broker=2] Cached zkVersion [428] not equal to that in zookeeper, skip updating ISR (kafka.cluster.Partition)
INFO [Partition topic-xxx-1 broker=2] Shrinking ISR from 2,5,4 to 2,5 (kafka.cluster.Partition)
你的答案