如何用kafka流在kafka中进行请求响应



我想用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/

最新更新