我在prod中使用了一个3代理kafka集群。现在我想把复制因子增加到3。我已经执行了kafka-reassignment-partions.sh文件，它执行成功。执行后当我执行descripe命令时，它在isr列表中显示了3个代理，但是对于所有部分，我都有相同的领导（代理1作为领导）。请建议
tzdcorbm1#
据我所知，您在“replicas”字段中输入的顺序反映了哪个代理将是该分区的领导者，因此对所有分区具有相同的[1,2,3]序列，并且代理1始终位于相同的第一位置，因此它将是该分区的领导者。您应该更改顺序，将您想要作为相应分区的前导的代理id放在第一个位置。之后，您必须运行首选的副本选择工具。
1条答案
按热度按时间tzdcorbm1#
据我所知，您在“replicas”字段中输入的顺序反映了哪个代理将是该分区的领导者，因此对所有分区具有相同的[1,2,3]序列，并且代理1始终位于相同的第一位置，因此它将是该分区的领导者。您应该更改顺序，将您想要作为相应分区的前导的代理id放在第一个位置。之后，您必须运行首选的副本选择工具。