Kafka：無効なブローカーからパーティションを移動します。

Question

無効なブローカーがありますが、実際には存在しません。私は誤って無効なIDを持つサーバーを起動しました。

しかし、話題の一つは前にこのブローカーに割り当てられました。

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: 

私はすでに

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

でパーティションを再割り当てしようとした。しかし、それは何も変わりません。私はカフカが元のブローカー100がそれからブローカー1にデータをコピーするまで上がるのを待っていると思いますか？

しかし、私はそれをしたくない場合はどうすればいいですか？このブローカーからすべてのデータを失うのは大丈夫です。カフカに新たなリーダーとリバランスの話題を選択させることができますか？手動でコマンドラインから

Answer 1

ただ推測しますが、bin/kafka-preferred-replica-election.sh --zookeeper zk_host：port/chrootメソッドを使用しようとしました。