刪除無效的代理信息來自kafka副本

Question

我試圖通過提供文檔中指定的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

Answer 1

我張貼的解決方案here。

自旋了的8

使用./kafka-topics.sh檢查節點8的ID的新的代理是在ISR柱。

一旦同步，您可以使用./kafka-reassign-partitions.sh將其作爲副本刪除。