时间戳

首页 > 解决方案 > “errors.deadletterqueue.topic.name”在 Confluent 5.0.1 中无效

apache-kafka - “errors.deadletterqueue.topic.name”在 Confluent 5.0.1 中无效

问题描述

我最近从 confluent 4.0.1 升级到了 confluent 5.0.1。bootstrap.server 的版本是 Kafka 1.0。在我的 HBaseSink 连接器中，我配置了新功能“errors.deadletterqueue.topic.name”，如下所示：

{ "name": "kafka-hbase4", "config": { "connector.class": "com.xxxx.hbase.sink.HBaseSinkConnector", .... "zookeeper.quorum": "xxxx:2181", “主题”：“oplog_demo.hbase_test1”，“errors.deadletterqueue.topic.name”：“error-topic-1”}}

程序正常工作正常但是，当我向HBase Sink Connector的主题发送一些错误消息时，例如一些中文单词“哈哈”，程序崩溃了，抛出了SerializationException，并且没有消息被“错误-主题 1”。

这是否意味着配置“errors.deadletterqueue.topic.name”不起作用？怎么会这样，我怎样才能使这个配置工作？

标签： apache-kafkaapache-kafka-connectconfluent-platform

解决方案

确保错误容限设置正确

"errors.tolerance": "all"

这是一个非常好的 DLQ 配置资源Connecting to Apache Kafka Kafka Connect Deep Dive – 错误处理和死信队列

推荐阅读