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

Question

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

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

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

每当我的外发kafka服务器宕机而我无法发布它时，我就需要它来审计错误计数。

Answer 1

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

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

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

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