Confluent 7.4.0 Kafka Connect报错,6.2.6版本正常求故障原因
故障原因分析
这个错误的核心是Confluent Kafka Connect 7.4.0与你的Kafka Broker 2.8.2版本存在兼容性不匹配,具体细节如下:
- Confluent Platform 7.4.0对应的Kafka内核版本是3.4.x,而Kafka在2.8.x之后的组协调协议逻辑有变更,新版本Connect的成员身份校验逻辑与2.8.2版本的Broker不兼容。
- 3.4.x版本的Kafka客户端(Kafka Connect本质是特殊的消费者客户端)在加入消费者组时,对成员ID的请求流程与旧版本Broker的处理逻辑不匹配,导致Broker返回
MemberIdRequiredException,进而触发重平衡失败。 - 根据Confluent官方兼容性规则,7.4.x系列的CP组件建议搭配的Kafka Broker最低版本为3.3.x,你的2.8.2版本远低于该要求,跨大版本的差异直接引发了协议层面的冲突。
内容的提问来源于stack exchange,提问作者tooptoop4
相关产品推荐
相关产品推荐

