如何用kafka流在kafka中做请求-响应？
我想用kafka流实现请求-响应模式，我使用spring boot kafka，其中添加了一些数据作为报头，命名为关联id，但是当kafka流API处理请求消息时，报头数据会丢失，无法发送到响应主题！我该怎么解决，还是用另一种方法？？
共有1个答案
对于(201,已接受）以外的请求，您不会有响应
数据会丢失
不，不会的
https://www.confluent.io/kafka-summit-lon19/hello-streams-inimotion-the-first-streams-mindset/
-
我们希望使用Kafka作为我们的企业服务总线（ESB）。 我知道kafka的大多数用例都是异步用例。 在我们的系统中，是否仍然可以使用kafka在两个endpoint之间进行请求-响应消息传递？
-
假设有Kafka主题顺序。数据以JSON格式存储： 定义订单的状态（待定-1，已完成-2）。 完成后如何在“已完成”上进行更改？ 正如我所知，Kafka主题是不可变的，我不能更改消息JSON，只需创建一个带有更改值的新消息，对吗？
-
我写了Kafka流应用程序，我想把它部署在Kafka集群上。因此，我构建了一个jar文件，并使用以下命令运行它：
-
TLDR：有一个请求/响应模式。目前，请求是通过激活队列完成的，响应是通过memcache键值存储完成的（由前端轮询）。出于各种原因，想转移到kafka，想知道我们是否可以重新构建响应路径，以不使用memcach。 我试图理解什么是针对以下问题的最佳实践系统设计。 我们有一个前端，可以生成需要大量处理的请求。应用程序需要响应才能升级。有时，我们需要撤消/后退（这会使您回到以前的状态）。有一组后端可
-
我的场景是我使用make很多共享前缀（例如house.door,house.room）的Kafka主题，并使用Kafka stream regex主题模式API消费所有主题。一切看起来都很好，我得到了数据的密钥和信息。 为了处理数据，我需要主题名，这样我就可以根据主题名进行连接，但我不知道如何在Kafka stream DSL中获得主题名。
-
我正在调查Kafka9作为一个爱好项目，完成了几个“你好世界”类型的例子。 我不得不考虑基于请求响应消息传递的真实世界的Kafka应用程序，更具体地说，是如何将Kafka请求消息链接到它的响应消息。 我的思路是使用生成的UUID作为请求消息键，并使用这个请求UUID作为关联的响应消息键。与WebSphere MQ具有消息关联ID的机制几乎相同。 我的end 2 end进程将是。 1）。Kafka客