Because of business requirements, we need to use a ReplyingKafkaTemplate with Kafka Streams playing the role of the consumer. We want to provide a support for exception management such that it is possible to escalate errors as part of the future response. We saw that the onMessage() method of this listener already handles deserialization errors and sets the exception on the future accordingly. We would like to enhance this behavior with more exceptions, but we couldn’t find any hook points. Is there any other location in the code where we can extend the implementation, or else do you think you might create an entry point for that?
Thank you for your help.