java—从kafka中的副本中删除无效的代理信息

pprl5pva  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(296)

我试图通过提供文档中指定的json来增加主题的复制因子。
https://kafka.apache.org/0102/documentation.html
我错误地在指定复制列表时放入了无效的代理id。即使回滚,无效的代理id也不会消失。
有办法解决吗。请帮忙 Topic: cms_scf_images_zip Partition: 16 Leader: 4 Replicas: 4,6,7,8 Isr: 4,6,7 Topic: cms_scf_images_zip Partition: 17 Leader: 5 Replicas: 5,7,1 Isr: 5,7,1 8是无效的代理id

zkure5ic

zkure5ic1#

我在这里发布了一个解决方案。
启动一个id为8的新经纪人。
使用./kafka-topics.sh检查节点8是否在isr列中。
同步后,可以使用./kafka-reassign-partitions.sh将其作为副本删除。

相关问题