error.deadletterqueue.topic.name 是否适用于源连接器

Question

"errors.deadletterqueue.topic.name"适用于源连接器吗？我使用JDBC 接收器连接器进行了测试，它可以工作，但我没有找到有序列化错误的记录进入死信队列。

我使用Debezium Connector for MongoDB，apache-kafka-connect版本是 2.4.0。

其余错误处理配置：

"errors.tolerance": "all",
"errors.log.enable": "false",
"errors.deadletterqueue.topic.name": "test-dlq",
"errors.deadletterqueue.context.headers.enable": "true"

Answer 1

apache-kafka-connect包含错误处理选项，包括从 Apache Kafka 2.0 到KIP-298 的将消息路由到死信队列的功能：Connect 中的错误处理。根据此 KIP，死信队列仅支持接收器连接器。

您也可以查看 Kafka Connect文档：

error.deadletterqueue.topic.name：用作死信队列 (DLQ) 的主题名称，用于处理由此接收器连接器或其转换或转换器时导致错误的消息。默认情况下，主题名称为空，这意味着 DLQ 中不会记录任何消息。

Robin Moffatt撰写的有关错误处理和死信队列的精彩文章