如何通过kafka生产者通知用户到消费者进程

Question

我有一个 REST API，它从用户那里获取数据并使用生产者 API 将该数据推送到 kafka 主题，现在消费者进程正在 运行 使用来自该主题的消息。 我需要为每条消息将消费者进程的状态发送到 API。 有什么办法可以实现吗？

Answer 1

Apache Kafka 是一个将生产者端与消费者端分离的消息队列。它没有为消费者提供直接与生产者交互的机制。

也就是说，您有几个选择。最常见的是简单地让处理端向 "producer side" 消费的另一个主题生成消息。这样一来，您的数据就会在一个方向流动，而状态会在另一个方向更新。

另一种选择是让消费者端调用生产者端的 REST API 端点来更新其状态。这有点不太优雅，但可以根据您的用例使用。