2
無効なブローカーがありますが、実際には存在しません。私は誤って無効なIDを持つサーバーを起動しました。Kafka:無効なブローカーからパーティションを移動します。
しかし、話題の一つは前にこのブローカーに割り当てられました。
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にデータをコピーするまで上がるのを待っていると思いますか?
しかし、私はそれをしたくない場合はどうすればいいですか?このブローカーからすべてのデータを失うのは大丈夫です。カフカに新たなリーダーとリバランスの話題を選択させることができますか?手動でコマンドラインから
ええ、私も試しましたが、何も変わっていませんでした:(結果として私は地面から全体のクラスタを作り直しました。それは大きな問題ではありませんでしたが、まだ質問です。 prodで同じ状況になる –