【发布时间】：2022-09-24 06:17:23
【问题描述】：
我目前正在配置一个 Kafka JDBC 接收器连接器，以在 Postgres 表中写入我的 kafka 消息。除错误处理部分外，一切正常。有时，我的主题中的消息包含错误的数据，因此数据库约束失败并出现预期的SQL EXCEPTION duplicate key...
我想将这些错误消息放入 DLQ 并提交偏移量以处理下一条消息，因此我将连接器配置为
\"errors.tolerance\": \"all\"
\"errors.deadletterqueue.topic.name\": \"myDLQTopicName\"
但它不会改变任何事情，连接器会重试直到崩溃。
我还缺少其他配置吗？我在融合文档中只看到了这两个
（我在jdbc connector changelog 中看到了放stage 在版本 10.1.0 (CCDB-192) 中实现，我正在使用连接器的最新版本 10.5.1)
标签： postgresql jdbc apache-kafka apache-kafka-connect