为同一主题创建多个使用者,而不在kafka中创建重复的偏移量

问题描述 投票:-1回答:1

我的问题

我有一个制作人。产生两次到主题名称t1的消息“ hello1”,“ hello2”。我有两个消费者名称c1,c2。所以我想让c1使用者消息“ hello1”和c2使用者消息“ hello2”。

但是现在,当我使用消息c1时,也获得“ hello1”,“ hello2”,而c2也获得“ hello1”,“ hello2”。我不要

问题

我如何创建2或3个使用者以订阅来自同一主题的消息而没有重复消息。

spring-boot apache-kafka spring-cloud-stream
1个回答
1
投票

您需要将两个消费者都放在同一个消费者组中。在消费者组内,一条消息将仅由单个消费者使用。

您可以使用group.id设置来设置消费者所属的组。有关此设置的详细信息,请参见http://kafka.apache.org/documentation/#consumerconfigs

请参阅涵盖消费者组基础知识的文档中的this section

© www.soinside.com 2019 - 2024. All rights reserved.