Spring Integration - Kafka Producer 错误通道

【问题标题】：Spring Integration - Kafka Producer Error ChannelSpring Integration - Kafka Producer 错误通道
【发布时间】：2017-08-07 08:23:41
【问题描述】：

我正在使用 Kafka 生产者向其他一些 kafka 主题发布消息，并且它工作得很好。下面的示例模板：

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

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

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

【问题讨论】：

【解决方案1】：

由于任何Outbound都是被动组件，它只能通过外部调用来达到它的目的，所以当我们调用服务方法时，错误处理应该类似于Java中的try...catch就不足为奇了。

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

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

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

【讨论】：