我已经开发了一个Kafka消费者和将有这个消费者在生产运行多个示例。我知道如何使用group.id来避免重复处理数据。有没有一种方法可以让所有的消费者都收到信息，但只向一个消费者发送一点信息？有没有一种方法可以为每个主题甚至主题中的每个键设置group.id？
ajsxfq5m1#
看来这跟Kafka没有关系。您已经知道，通过为每个使用者提供一个唯一的group.id，所有使用者示例都将获得来自该主题的所有消息。现在，就push to db而言，您可以考虑出这个逻辑并尝试使用 distributed lock 因此，应用程序的push-to-db部分只能由一个使用者执行。这是基于java的设置吗？
distributed lock
1条答案
按热度按时间ajsxfq5m1#
看来这跟Kafka没有关系。您已经知道，通过为每个使用者提供一个唯一的group.id，所有使用者示例都将获得来自该主题的所有消息。现在，就push to db而言，您可以考虑出这个逻辑并尝试使用
distributed lock因此，应用程序的push-to-db部分只能由一个使用者执行。这是基于java的设置吗？