Ungültige Brokerinformationen aus Replikaten in Kafka entfernen

Question

Ich habe versucht, den Replikationsfaktor eines Themas zu erhöhen, indem ich einen JSON wie in docs angegeben zur Verfügung stelle.

https://kafka.apache.org/0102/documentation.html

Versehentlich setzen i ungültig Broker-ID Replikationsliste in angeben. Selbst wenn das Rollback ausgeführt wurde, wird diese ungültige Broker-ID nicht gelöscht.

Gibt es eine Möglichkeit, es zu beheben. Bitte helfen

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 ist die ungültige Broker-ID

Answer 1

I here eine Lösung gepostet.

Spin ein neuer Broker mit einem ID von 8 bis

Verwendung ./kafka-topics.sh diesen Knoten überprüfen 8 ist im ISR Spalte.

Sobald es synchronisiert ist, können Sie ./kafka-reassign-partitions.sh verwenden, um es als Replikat zu entfernen.