使用Kafka流的ReplyingKafkaTemplate异常管理

Question

由于业务需求，我们需要使用一个ReplyingKafkaTemplate，其中卡夫卡流扮演了消费者的角色。我们希望提供对异常管理的支持，这样就可以将错误升级作为未来响应的一部分。我们看到这个侦听器的onMessage()方法已经处理反序列化错误，并相应地设置了将来的异常。除了更多的例外情况，我们想要增强这种行为，但是我们找不到任何挂钩点。在代码中还有其他位置可以扩展实现，或者您认为您可能会为此创建一个入口点吗？

谢谢你的帮助。

Answer 1

如果您的意思是服务器端以某种方式返回错误(标头等)，则不，当前没有该用例的扩展点，但是添加对该用例的支持非常简单。

请打开一个功能请求https://github.com/spring-projects/spring-kafka/issues

我们应该能够让它进入下周的2.6.7版。