部署Debezium连接器报Leader not known错误50004如何解决？

该故障根因完全出在Schema Registry服务本身，与Debezium连接器、Kafka Connect的配置逻辑无直接关联：

• Debezium在执行快照阶段生成库表结构变更事件后，需要调用Avro转换器将数据序列化为Avro格式，该过程需要向Schema Registry注册对应数据的Schema
• Schema Registry返回Leader not known错误（错误码50004），代表Schema Registry集群无法选举出主节点，无法处理Schema注册请求，进而触发Kafka Connect的错误处理容错阈值，连接器任务被强制终止，快照流程中断
• Schema Registry的主节点选举依赖底层Kafka集群的内置主题_schemas，该主题存储所有Schema元数据，出现UnknownLeaderException说明该主题的Leader副本不可用，或Schema Registry集群无法和Kafka集群通信获取该主题的Leader信息

1. 检查Kafka集群状态
   • 首先确认_schemas主题的副本状态是否正常，执行命令：

   kafka-topics.sh --describe --topic _schemas --bootstrap-server <kafka-bootstrap地址>
   

   • 检查输出的Leader列是否为有效broker ID，ISR列表是否包含正常在线的broker。如果Leader为-1或ISR为空，说明该主题不可用，需要先修复Kafka集群故障节点，或调整_schemas主题的副本配置，保证所有副本都分布在正常在线的broker上。
2. 检查Schema Registry集群配置
   • 确认配置项kafkastore.bootstrap.servers指向的Kafka集群地址正确，且Schema Registry节点与Kafka集群的网络连通、端口可访问。
   • 若为多节点Schema Registry集群，确认所有节点的kafkastore.group.id配置一致，且节点之间无网络、端口冲突问题。
3. 验证Schema Registry服务可用性
   修复完成后调用接口验证服务状态：

   curl http://<schema-registry地址>:8081/subjects
   

   若正常返回已有Schema的subject列表，说明服务已恢复。
4. 重启Debezium连接器任务
   确认Schema Registry正常后，重启失败的Debezium连接器即可继续执行快照流程，无需调整Debezium现有配置。

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