我想用kafka流实现request-response模式,我使用spring boot kafka,它添加一些数据作为头,命名为correlation-id,但当请求消息被kafka stream API处理时,头数据会丢失,无法发送到响应主题!我该如何解决,或者使用其他方法??
除了(201, accepted)
之外,您不会对请求做出响应
数据将丢失
不,不会
无法发送到响应主题!
为什么不呢?
我如何解决它,或者使用其他方法??
使用WebSockets获取响应。
你可能想看这个使用多个Spring应用程序的演讲。
https://www.confluent.io/kafka-summit-lon19/hello-streams-introducing-the-first-streams-mindset/