Kafka 2.2.1 Broker集群搭配2.7.1客户端能否使用CooperativeStickyAssignor?
Kafka CooperativeStickyAssignor 版本兼容性问题解答
问题1:Kafka集群版本2.2.1是否支持使用CooperativeStickyAssignor?
不支持。CooperativeStickyAssignor是在Kafka 2.3.0版本才正式引入的特性,同时它依赖Broker端对协作式重平衡(Cooperative Rebalance)协议的支持。2.2.1版本的Kafka Broker完全没有相关底层逻辑,无法配合该分配器工作。
问题2:Kafka Broker集群版本为2.2.1,客户端版本为2.7.1,客户端库中包含CooperativeStickyAssignor,是否支持使用该分配器从该集群消费消息?
仍然不支持。协作式重平衡需要Broker和客户端双方都支持对应的协议交互,2.2.1的Broker不识别协作式重平衡的相关请求,会导致消费组重平衡失败,客户端可能无法正常加入消费组,甚至抛出协议不兼容的异常。
另外需要注意:客户端与Broker版本跨度过大(从2.2.1到2.7.1跨了5个小版本)本身就存在较高兼容性风险,建议尽量保持客户端与Broker版本一致性,至少不要跨超过2个小版本。
内容的提问来源于stack exchange,提问作者DeepNightTwo
相关产品推荐
相关产品推荐

