我有一个问题,我的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。如果数据实际上不存在于“新代理”中,则可能导致数据丢失