Kafka支持请求响应消息传递吗

Question

我正在调查Kafka9作为一个爱好项目，完成了几个“你好世界”类型的例子。

我不得不考虑基于请求响应消息传递的真实世界的Kafka应用程序，更具体地说，是如何将Kafka请求消息链接到它的响应消息。

我的思路是使用生成的UUID作为请求消息键，并使用这个请求UUID作为关联的响应消息键。与WebSphere MQ具有消息关联ID的机制几乎相同。

我的end 2 end进程将是。

1）。Kafka客户端生成随机UUID并发送单个Kafka请求消息。2）。服务器将使用此请求消息提取并存储请求UUID值。3）。使用消息有效负载完成业务流程。4）。使用响应消息响应，该响应消息使用从请求消息中存储的UUID值作为响应消息键。5）。Kafka客户端轮询响应主题，直到它超时或检索到具有原始请求UUID值的消息。

我担心的是，Kafka消费者轮询将从响应主题中删除其他客户端消息，并增加偏移，从而使其他客户端失败。

我是否试图在一个从未为其设计的用例中应用Kafka？

是否可以在Kafka中实现请求/响应消息传递？

Answer 1

即使Kafka提供了方便的方法来持久化给定的消费者组的已提交的偏移，您也不需要使用该行为，如果您觉得有必要，可以编写您自己的行为。即使如此，您所描述的Kafka的使用对于用例来说还是有点尴尬的，因为每个客户机都需要重复地搜索主题以获得特定的响应。那充其量是低效的。

您可以将问题分成两部分，继续使用Kafka向服务器发送请求和从服务器发送响应。您需要添加的唯一部分是某种API层，您的客户机与该层进行对话，它封装了来自客户机的特定于Kafka的逻辑。这一层需要一个本地DB（关系或NoSQL)，它可以按uuid存储响应，从而使API能够快速、轻松地回答响应是否可用于特定的uuid。