我有一个关于复制因子3的主题“reptop”。我的集群由4个代理组成[ID:0,1,2,3]。当主题被创建时，代理0、2和3被分配给该主题，其中leader为“2”，现在当我的一个代理、leader或follower倒下时，kafka不会将该主题复制到broker:1 even 虽然它是健康的，而且isr小于复制因子，但是当代理程序停止运行并最初分配给主题时，返回kafka将主题复制到此节点。所以问题是，为什么kafka不将主题复制到创建主题时未分配主题的代理，即使集群上有健康的代理和“isr”
1条答案
按热度按时间cld4siwp1#
这是故意的。如果要重新分配分区，必须使用重新分配工具。另一种选择是使用丢失的id创建一个新的代理示例。kafka不像hdfs那样“自我修复”，而且在很多情况下您不希望它这样做。如果你想的话，有人告诉你，就像汇合再平衡，可以使用。