Debezium Postgres连接器在“搜索WAL恢复位置”后故障

从错误栈可以明确，连接器崩溃的核心原因是与Apicurio Schema Registry通信失败——在尝试自动创建Schema Artifact时抛出了Rest客户端异常，最终触发Kafka Connect的错误容忍阈值，导致任务终止。日志中WAL恢复位置显示为null，大概率是首次启动或偏移量丢失，但这并非直接崩溃原因。

• 检查Apicurio Registry的可达性
  确认Connect集群能正常访问Apicurio Registry的地址，用telnet或curl测试Registry的REST端口，排查是否有防火墙、网络策略拦截请求。

• 验证Registry状态与权限

  • 查看Apicurio Registry服务日志，确认服务正常运行，无启动失败、资源不足等异常。
  • 核对连接器配置中的Registry认证信息（若开启认证），确保账号具备创建Artifact的权限。

• 调整Schema自动创建配置
  若无需自动创建Schema，可修改连接器的Converter配置关闭该功能：

  key.converter=io.apicurio.registry.utils.converter.ExtJsonConverter
  key.converter.apicurio.registry.auto-create=false
  value.converter=io.apicurio.registry.utils.converter.ExtJsonConverter
  value.converter.apicurio.registry.auto-create=false
  

  或提前在Apicurio Registry中手动创建对应表的Schema Artifact，确保连接器能匹配到已有Schema。

• 提升错误重试与容忍度
  修改Kafka Connect任务级配置，提高重试次数和超时时间，避免单次通信失败直接终止任务：

  errors.retry.timeout=300000
  errors.retry.max=10
  errors.tolerance=all
  

• 检查版本兼容性
  确认Debezium连接器版本与Apicurio Registry版本兼容，避免因API版本不匹配导致交互异常。

• 重置连接器偏移量
  因日志显示WAL恢复位置为null，可尝试重置连接器偏移量后重启，让连接器从初始位置同步：

  curl -X POST http://<connect-host>:<port>/connectors/<connector-name>/offsets/reset
  

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