我正在为kafka connect编写http接收器插件。它的目的是为配置的kafka主题中的每条消息发送http请求。如果http请求失败,我想将消息发送到死信队列。我可以使用sink插件中提供的死信队列配置吗?
这个问题的原因是,kafka connect文档和一些博客中提到,只有transformer和converter中的错误才会被发送到死信队列,而不是put期间的错误。因为发送http请求的任务是在put中完成的。所以我想,有没有一种方法可以将失败的http消息发送到dlq?如果没有,是否可以将消息发送到其他Kafka主题以进行进一步处理?
暂无答案!
目前还没有任何答案,快来回答吧!