Spring 集成 - Kafka 生产者错误通道

Question

我正在使用 Kafka producer 将消息发布到其他一些 kafka 主题并且它工作得很好。以下示例模板：

<int-kafka:outbound-channel-adapter 
                kafka-template="template" 
                channel="inputToKafka"
                topic="foo"/>

以上语句是否支持kafka消息驱动的入站通道适配器所支持的errorchannel？

每当我的传出 kafka 服务器关闭并且我无法发布它时，我需要它来审核错误计数。

Answer 1

由于任何 Outbound 都是被动组件，它只能通过外部调用来实现其目的，因此错误处理应该类似于 [=24 中的 try...catch 也就不足为奇了=] 当我们调用服务方法时。

因此，一种方法是在上游设置错误通道 - 消息网关或入站通道适配器。

另一种方法是在<int-kafka:outbound-channel-adapter>的request-handler-advice-chain中使用ExpressionEvaluatingRequestHandlerAdvice。

此外，请记住，您应该使用 async = false 选项在同一线程中获取来自 Kafka 交互的所有错误。

Spring Integration - Kafka Producer Error Channel