You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.20 03:52:03