Spring Integration - Kafka Producer错误频道

作者: polo
发布时间: 2024-04-06 09:39:25 (13天前)
转自：

2 条回复

0#
回复此人
凯撒 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 既然如此 <code> Outbound </code> 是被动组件，它只能通过外部调用来实现其目的，这并不奇怪，错误处理应该类似于 <code> try...catch </code> 在Java中我们调用服务方法。 </p> <P> 因此，一种方法是在上游使用错误通道 - Messaging Gateway或Inbound channel Adapter。 </p> <P> 另一种方法是使用 <code> ExpressionEvaluatingRequestHandlerAdvice </code> 在里面 <code> request-handler-advice-chain </code> 的 <code> <int-kafka:outbound-channel-adapter> </code> 。 </p> <P> 另外，请记住你应该使用 <code> async = false </code> 选项以在同一个线程中从Kafka交互中获取所有错误。 </p> </DIV>

编辑

登录后才能参与评论