Kafka:如何获得消费者的回应？

Question

我想描述以下场景：我有一个节点。js后端应用程序（它使用单线程事件循环）。这是系统的总体架构：Producer-

假设制作者向Kafka发送了一条消息，这条消息的目的是在数据库中进行某个查询并检索查询结果。但是，众所周知Kafka是一个异步系统。如果制作者向Kafka发送消息，它会得到一个响应，表明该消息已被Kafka经纪人接受。Kafka broker不会等到消费者轮询消息并处理它。

在这种情况下，生产者如何获得在数据库上操作的查询结果？

Answer 1

您必须生成新的流以传递查询结果：

Consumer (now its a producer) -> Kafka topic -> Producer (now its a consumer)

您应该考虑使用另一种同步通信机制，如HTTP。

Answer 2

使用 Kafka 的流程将如下所示：

生产者 A 了解使用者 A 使用的消息发生了什么情况的唯一方法是生成另一条消息。这将由任何其他可用的消费者（在本例中为消费者 B）相应地处理。

正如您已经提到的，这个流程是异步的。当您的查询处理量非常大时，比如生成报告或类似的事情，第二个生成器会通知用户收件箱，这就非常有用。

如果不是这种情况，也许您应该使用 HTTP，它是同步的，您将在处理结束时获得响应。