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