使用kafka流的replyingkafkatemplate的spring异常管理

9njqaruj  于 2021-07-23  发布在  Java
关注(0)|答案(1)|浏览(345)

由于业务需求,我们需要使用一个带有kafka流的replyingkafkatemplate来扮演消费者的角色。我们希望为异常管理提供支持,以便可以将错误升级为未来响应的一部分。我们看到这个监听器的onmessage()方法已经处理了反序列化错误,并相应地在将来设置了异常。我们希望通过更多的异常来增强此行为,但找不到任何挂钩点。代码中是否有其他位置可以扩展实现,或者您是否认为可以为此创建一个入口点?
谢谢你的帮助。

fwzugrvs

fwzugrvs1#

如果您的意思是服务器端通过某种方式(头等)返回错误,那么不,目前没有该用例的扩展点,但是添加对该用例的支持将是微不足道的。
请打开功能请求https://github.com/spring-projects/spring-kafka/issues
我们应该可以把它放到下周的2.6.7版本中。

相关问题