4.是kafka源码里面的 这个的确问的有点深了 没看过源码真回答不上来(2. canRebalance: - 功能:判断消费者组当前是否能发起 Rebalance。 - 逻辑:检查当前状态是否是 PreparingRebalance 状态的合法前置状态(即 Stable, CompletingRebalance, Empty)。)大概是这样一个逻辑

相关推荐

牛客网
牛客网在线编程
牛客网题解
牛客企业服务