This issue has clear positioning, increase the partition, the colleague's code used in 0.10 AdminUtils, the replicas of the partitions of the existing distribution redistribution, and directly write into the znode, to the normal controller failed to deal with this logic, I run the kafka is 2.0.0 version, don't know whether the latest kafka versions will deal with this exception, or is it a optimization problem?
wenbing shen <oliver.shen...@gmail.com> 于2021年3月11日周四 下午11:07写道： > [image: image.png] > This is a screenshot of a problem occurred in our product at the customer > site. Does anyone know the reason? > > wenbing shen <oliver.shen...@gmail.com> 于2021年3月11日周四 下午7:17写道： > >> A large number of Replicas of the topic are inconsistent with isr, an >> example of which is as follows: >> Topic: td_tip Partition: 0 Leader: 1001 Replicas: >> 1003,1005 Isr: 1001,1002 >> Topic: td_tip Partition: 1 Leader: 1006 Replicas: >> 1004,1007 Isr: 1006,1009 >> Topic: td_tip Partition: 2 Leader: 1011 Replicas: 1020,1022 >> Isr: 1012,1011 >> Topic: td_tip Partition: 3 Leader: 1009 Replicas: >> 1015,1016 Isr: 1009,1008 >> >
