Kafka JDBC Sink连接器DLQ配置无效，仍持续重试直至崩溃

针对你遇到的重复键错误无法转入DLQ、连接器持续重试崩溃的问题，大概率是遗漏了关键配置或现有配置冲突，以下是具体排查点：

• 必须补充errors.deadletterqueue.topic.replication.factor配置
  这是DLQ功能生效的必填项，虽然Confluent文档未强制强调，但如果不指定，Kafka无法自动创建符合集群要求的DLQ主题，导致错误消息无处可去，连接器只能持续重试。根据你的集群规模设置：单节点集群设为1，多节点集群建议设为2或3：

  "errors.deadletterqueue.topic.replication.factor": "1"
  

• 调整max.retries和retry.backoff.ms
  即便开启了errors.tolerance=all，如果max.retries设置了较大值（默认可能不为0），连接器会先完成指定次数的重试，才会将消息转入DLQ。如果不想重试直接入DLQ，把max.retries设为0即可：

  "max.retries": "0"
  

• 检查配置格式正确性
  确保你的JSON配置项间用逗号分隔，比如你给出的配置里缺少逗号，正确格式示例：

  "errors.tolerance": "all",
  "errors.deadletterqueue.topic.name": "myDLQTopicName",
  "errors.deadletterqueue.topic.replication.factor": "1",
  "max.retries": "0"
  

  格式错误会导致连接器忽略错误处理配置，直接沿用默认的重试逻辑。

• 排查权限与日志
  查看连接器的运行日志，确认是否存在DLQ主题创建失败、权限不足的报错（比如连接器没有创建/写入DLQ主题的Kafka ACL权限）。这类问题会导致DLQ无法正常工作，连接器只能不断重试错误消息。

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