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

【问题标题】：Does errors.deadletterqueue.topic.name work for source connectorerrors.deadletterqueue.topic.name 是否适用于源连接器
【发布时间】：2020-06-03 09:54:27
【问题描述】：

"errors.deadletterqueue.topic.name" 是否适用于源连接器？我用JDBC sink connector 进行了测试，它可以工作，但是我没有发现有序列化错误的记录进入死信队列。

我使用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"

【问题讨论】：

标签： apache-kafka-connect apache-kafka apache-kafka-connect dead-letter

【解决方案1】：

apache-kafka-connect 包含错误处理选项，包括从 Apache Kafka 2.0 到KIP-298: Error Handling in Connect 将消息路由到死信队列的功能。根据这个 KIP，Dead Letter Queue 是 supported 仅适用于 Sink 连接器。

您也可以查看 Kafka Connect docs：

errors.deadletterqueue.topic.name：将用作死信队列 (DLQ) 的主题的名称，用于在此接收器连接器处理时导致错误的消息，或其转换或转换器。主题名称默认为空，表示DLQ中不记录任何消息。

Robin Moffatt 撰写的关于Error Handling and Dead Letter Queues 的精彩文章

【讨论】：