春季集成 - 卡夫卡制片人错误频道

Question

我正在使用卡夫卡制作人发布消息给其他卡夫卡主题，其工作相当好。下面的示例模板：

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

请问上述声明支持errorchannel在卡夫卡消息驱动的入站通道适配器支持？

我需要这个审计错误计数，每当我的传出kafka服务器关闭，我无法发布它。

Answer 1

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

所以，一种方法是有错误通道上游 - 消息网关或入站通道适配器。

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

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