Spring积分-Kafka生产者误差通道

Question

我正在使用Kafka生产者发布消息到一些其他Kafka的主题，它的工作相当好。下面的示例模板：

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

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

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

Answer 1

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

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

另一种方法是在 的request-handlerchain中使用ExpressionEvaluatingRequestHandlerAdvise。

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