卡夫卡的死信队列连接http接收器

问题描述

我正在为Kafka连接编写HTTP Sink插件。其目的是为已配置的Kafka主题中的每个消息发送HTTP请求。我想将邮件发送到死信队列，以防HTTP请求失败。我可以使用接收器插件中提供的死信队列配置吗？

这个问题的原因是，在kafka connect文档和一些博客中已经提到，只有变压器和转换器中的错误将被发送到死信队列，而不是PUT期间的错误。由于发送http请求的任务是在PUT中完成的。因此，我认为有没有办法将失败的http消息发送到DLQ？如果不是，是否可以将消息发送到其他kafka主题以进行进一步处理？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）