由于业务需求，我们需要使用ReplyingKafkaTemplate，其中Kafka Streams扮演消费者的角色。我们希望为异常管理提供支持，以便可以将错误升级作为 future 响应的一部分。我们看到该监听器的 onMessage() 方法已经处理了反序列化错误，并相应地设置了 future 的异常。我们希望通过更多异常(exception)来增强此行为，但我们找不到任何 Hook 点。代码中是否还有其他位置可以扩展实现，或者您认为可以为此创建一个入口点？
感谢您的帮助。
最佳答案
如果您的意思是服务器端通过某种方式返回错误( header 等)，不，当前没有针对该用例的扩展点，但添加对此的支持将是微不足道的。
请提出功能请求 https://github.com/spring-projects/spring-kafka/issues
我们应该能够将其纳入下周的 2.6.7 版本中。
关于spring - 使用 Kafka Streams 的 ReplyingKafkaTemplate 异常管理，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/66549328/