微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

如何解决卡夫卡的死信队列连接http接收器

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

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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。