我有一个问题，我的Kafka主题没有领导者。是否有一个解决方案，我可以重新选择一个领导者为我的所有主题？
CSVForOldSystem PartitionCount: 1 ReplicationFactor: 1 Configs: segment.bytes=1073741824
Topic: CSVForOldSystem Partition: 0 Leader: none Replicas: 1001 Isr: 1001我想我需要一个领导者或不？Broker的ID为1006
我需要重新选举一个领导人，但我不知道怎么做。
1条答案
按热度按时间bqjvbblv1#
如果你只有一个经纪人，那么你的选择包括
1.编辑server.properties以显式地设置broker.id =1001。但是，这将破坏现在以1006为领导者的任何新的现有主题
1.你需要使用
kafka-reassign-partitions脚本来修改该主题的代理ID，所有其他的都使用1006而不是1001。如果数据实际上不存在于“新代理”中，则可能导致数据丢失