Работает ли error.deadletterqueue.topi c .name для исходного соединителя - PullRequest
Новая
       119

Работает ли error.deadletterqueue.topi c .name для исходного соединителя

1 голос
/ 19 февраля 2020

Работает ли "errors.deadletterqueue.topic.name" для разъема источника? Я протестировал с JDB C коннектором приемника , и он работает, но я не могу найти запись с ошибкой сериализации, которая попадает в очередь недоставленных писем.

Я использую коннектор Debezium для MongoDB и версия 2.4.0.

Конфигурация обработки остальных ошибок: 

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

1 Ответ

1 голос
/ 19 февраля 2020

включает опции обработки ошибок, в том числе функциональность для маршрутизации сообщений в очередь мертвая буква с Apache Kafka 2.0 до KIP-298 : обработка ошибок в Connect . Согласно этому KIP, Dead Letter Queue поддерживается только для коннекторов раковины .

Также вы можете проверить Kafka Connect документы :

errors.deadletterqueue.topi c .name : Имя topi c, которое будет использоваться в качестве очереди недоставленных сообщений (DLQ) для сообщений, которые приводят к ошибке при обработке этим коннектором приемника или его преобразователями или преобразователями. Имя topi c по умолчанию пустое, что означает, что в DLQ не должно быть записано никаких сообщений.

Отличная статья о Обработка ошибок и мертвая буква Очереди Робин Моффат

...