时间戳

首页 > 解决方案 > errors.deadletterqueue.topic.name 是否适用于源连接器

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

问题描述

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

我为 MongoDB 使用 Debezium 连接器，版本是 2.4.0。

其余错误处理配置：

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

标签： apache-kafkaapache-kafka-connectdead-letter

解决方案

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

您还可以查看 Kafka Connect文档：

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

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

推荐阅读