Kafka: Partition von ungültigem Broker verschieben

Question

Ich habe einen ungültigen Broker, der nicht wirklich existiert. Ich habe aus Versehen einen Server mit ungültiger ID gestartet.

Aber eines der Themen zu diesem Broker vor zugewiesen wurde:

Topic:raw-logs PartitionCount:3 ReplicationFactor:1 Configs: 
    Topic: raw-logs Partition: 0 Leader: -1  Replicas: 100 Isr: 
    Topic: raw-logs Partition: 1 Leader: none Replicas: 2  Isr: 
    Topic: raw-logs Partition: 2 Leader: none Replicas: 3  Isr: 

habe versucht, ich bereits Partitionen mit

{"topic":"raw-logs","partition":0,"replicas":[1]} 

neu zuzuweisen Aber es ändert nichts. Ich schätze, Kafka wartet, bis der ursprüngliche Broker 100 hochgeht, um Daten von ihm zu Broker 1 zu kopieren. Habe ich recht?

Aber was ist, wenn ich es nicht will? Ich bin in Ordnung, alle Daten von diesem Broker zu verlieren. Kann ich Kafka zwingen, ein neues Leader- und Rebalancethema auszuwählen? Manuell, von der Befehlszeile

Answer 1

nur Raten, aber haben Sie versucht, die bin/kafka-preferred-replica-election.sh --zookeeper zk_host: port/chroot-Methode zu verwenden.