我的问题
我有一个制片人。生成两次消息“hello1”，“hello2”到主题名t1。我有两个消费者名字c1，c2。所以我想要c1消费信息“hello1”和c2消费信息“hello2”。
但现在当我使用消息c1时，得到“hello1”，“hello2”，c2也得到“hello1”，“hello2”。我不要。
问题
如何创建2或3个使用者来订阅来自同一主题的消息而不产生重复消息。
我的问题
我有一个制片人。生成两次消息“hello1”，“hello2”到主题名t1。我有两个消费者名字c1，c2。所以我想要c1消费信息“hello1”和c2消费信息“hello2”。
但现在当我使用消息c1时，得到“hello1”，“hello2”，c2也得到“hello1”，“hello2”。我不要。
问题
如何创建2或3个使用者来订阅来自同一主题的消息而不产生重复消息。
1条答案
按热度按时间vdgimpew1#
您需要在同一个消费者组中同时拥有两个消费者。在使用者组中，消息将仅由单个使用者使用。
您可以使用
group.id设置。看到了吗http://kafka.apache.org/documentation/#consumerconfigs 有关此设置的详细信息。请参阅文档中的本节，其中介绍了有关消费群体的基本知识