2016-05-31 22 views
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]} 

但它不會改變任何東西。我猜Kafka會等到原來的Broker 100纔會將數據從它複製到Broker 1.我是對的嗎?

但是如果我不想要它呢?我很好從這個經紀人丟失所有數據。我可以強迫卡夫卡選擇新的領導者並重新平衡話題嗎?手動,從命令行

回答

0

只是猜測,但你試過使用bin/kafka-preferred-replica-election.sh --zookeeper zk_host:port/chroot方法。

+0

是的,我也試過了,沒有任何改變:(因此我從地面重新創建了整個羣集,這是測試環境,所以不是一個大問題,但仍然是一個問題如果我要做什麼在產品中獲得相同的情況 –

相關問題