num.replica.fetchers 这个可以调大试试
节点满足这2个“同步”条件,以区分“活着”还是“故障”。leader跟踪“同步”节点。如果一个follower死掉,卡住,或落后,leader将从同步副本列表中移除它。落后是通过replica.lag.max.messages
配置控制,卡住是通过replica.lag.time.max.ms
配置控制的。
好的,感谢回答,还有个问题,就是kafka正常使用的情况下,如何解决 follower 跟不上leader问题,可以调整什么参数吗?
这个是消费者调度逻辑声明,不满足条件,不会进行rebalance的。
你可以观察,kafka与消费者保持的是长连接,如果你新增的时候,连接的端口一直是原来的(每次建议连接端口是随机的),那说明从未平衡过。