【发布时间】：2021-03-09 14:59:26
【问题描述】：
由于业务需求，我们需要使用一个ReplyingKafkaTemplate 和Kafka Streams 扮演消费者的角色。我们希望为异常管理提供支持，以便将错误升级为未来响应的一部分。我们看到这个监听器的 onMessage() 方法已经处理了反序列化错误，并相应地在未来设置了异常。我们希望通过更多异常来增强这种行为，但我们找不到任何挂钩点。代码中是否还有其他位置可以扩展实现，或者您认为您可以为此创建一个入口点吗？
感谢您的帮助。
【问题讨论】：
标签： spring spring-boot apache-kafka-streams spring-kafka