在 Kafka 中使用 high-level consumer API，如何配置不同的 consumer group?

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 2787 天前的主题，其中的信息可能已经有所发展或是发生改变。

问题描述： Kafka 中如何配置 consumer group id ，才能让一条消息在不同的 consumer group 消费。 producer 中给定 group id 可以发布消息到该组。但是在 consumer 中, 怎么配置呢？

第一次尝试，对 kafka 还是不太理解。

6 条回复 • 2017-04-05 13:59:22 +08:00

bbx

2017-04-05 11:59:51 +08:00 via iPhone

不需要配置吧。你说的是的 topic 吧

qiu0130

2017-04-05 12:18:59 +08:00 via Android

@bbx 不是，是 consumer group id, 在 producer 发布消息的时候指定该 group,不同的 group 可以共同消费该消息，这样一条消息就可以多次消费匠了。

vietor

2017-04-05 12:25:25 +08:00 via Android

是 client 的参数吧

blackFool

2017-04-05 12:26:37 +08:00

生产方写消息进一个 topic ，消费方消费这个 topic ，每个消费方配一个 consumer group ，只要 consumer group 不同，就能互不影响的消费 topic 里的消息，一条消息就能被他们都消费到。

qiu0130

2017-04-05 13:02:04 +08:00

@vietor
@blackFool 谢谢了，我明白了。生产方是 push 模式，消费方是 pull 模式，消费方指定不同的 group 该组就能拉到消息。

codeyung

2017-04-05 13:59:22 +08:00

你不一样的 groupid 就可以啊想消费同一个 topic 的话