AKS上Debezium SQL DB连接器偶发InconsistentGroupProtocolException问题求助

错误核心原因 #

这个错误本质是Kafka消费者组内成员的协议不兼容：要么新加入/重启的成员支持的协议和组内现有成员不匹配，要么成员加入时未携带合法的协议类型/列表。

关键概念厘清（你的Group ID疑惑） #

• Dockerfile中配置的Group ID（通常是GROUP_ID环境变量）是Kafka Connect集群自身的协调组ID，用来管理Connect节点的任务分配、故障转移等集群级协调工作，和Debezium发布消息的逻辑无关。
• schema.history.internal.consumer.group.id是Debezium专属的内部消费者组ID，仅用于同步schema变更的topic，和Connect集群的协调组完全独立。
• 你将这两个ID设为同一个，是触发错误的核心原因：Kafka会把两个用途完全不同的组当成同一个消费者组，而它们支持的协议完全不同（Connect集群用connect协议，内部schema消费者用普通消费者协议），一旦有节点重启或新成员加入，就会触发协议不兼容检查失败。

具体解决方案 #

• 立即修正组ID冲突：将schema.history.internal.consumer.group.id改成与Connect集群Group ID完全不同的值。例如Connect集群Group ID为connect-prod-cluster，则schema历史组ID可设为debezium-schema-history-prod，彻底隔离两个组。
• 清理旧的冲突组元数据：如果之前已用相同ID运行过，执行Kafka命令删除残留的冲突组：

  kafka-consumer-groups.sh --bootstrap-server <你的Kafka地址> --delete --group <冲突的组ID>
  

• 确保Connect集群配置一致性：所有Connect节点的GROUP_ID必须保持一致，但严禁与任何内部消费者组ID重复；同时不要修改group.protocol.type参数，Connect集群默认使用connect协议，不要改成普通消费者协议。
• 排查Pod重启触发场景：这个错误偶发出现，通常是AKS Pod因资源回收、滚动更新等原因重启导致的，可检查Pod重启日志，确认报错时间点是否与Pod重启时间吻合，验证触发逻辑。
• 版本兼容性检查：确保Debezium连接器版本与Kafka Connect版本完全兼容，版本不匹配也可能导致协议支持不一致。

内容的提问来源于stack exchange，提问作者Sindhu