如何使用具有 2 个具有不同组 ID 的消费者的单个应用程序实例加入 kafka 主题

Question

我有一个场景，我需要在同一个应用程序中创建 2 个消费者，具有 2 个不同的组 ID，并且都使用来自同一主题的消息。实现它的理想方法是什么？

我已经尝试过了，但是看起来一旦第二个消费者订阅了主题（具有不同的组 ID），第一个消费者就会变得不高兴并向协调器发送离开组请求并且以后不会加入。

谢谢。

Answer 1

你设置了 group.instance.id 了吗？这可能是您正在寻找的：https://www.confluent.io/blog/dynamic-vs-static-kafka-consumer-rebalancing/

一个附带的问题：为什么你想在同一个应用程序中两次使用同一个主题？一个更好的方法是将数据保存在本地。