我有一个restapi，它从用户那里获取数据，并使用producerapi将数据推送到kafka主题，现在正在运行一个consumer进程来使用来自这个主题的消息。我需要为每条消息向api发送使用者进程的状态。有没有办法做到这一点？
6l7fqoea1#
apachekafka是一个消息队列，它将生产者端和消费者端解耦。它没有为消费者提供一种直接与生产者互动的机制。也就是说，你有几个选择。最常见的方法是简单地让处理端生成一条消息，发送给另一个主题，该主题由“生产者端”使用。这样，您的数据在一个方向流动，状态在另一个方向更新。另一种选择是让使用者端调用生产者端的restapi端点来更新其状态。这是有点不优雅，但可以根据您的用例工作。
1条答案
按热度按时间6l7fqoea1#
apachekafka是一个消息队列，它将生产者端和消费者端解耦。它没有为消费者提供一种直接与生产者互动的机制。
也就是说，你有几个选择。最常见的方法是简单地让处理端生成一条消息，发送给另一个主题，该主题由“生产者端”使用。这样，您的数据在一个方向流动，状态在另一个方向更新。
另一种选择是让使用者端调用生产者端的restapi端点来更新其状态。这是有点不优雅，但可以根据您的用例工作。