2017-10-04 813 views
1

很奇怪,我无法在网上轻松找到这些信息,但我无法。所以,我的问题是我有一个卡夫卡话题。我希望两个彼此独立的消费者组消费这个主题的消息。所以,我想要的是两个消费者群体都能够看到并消费彼此独立的所有消息。为了更加清楚,我不想让一个消费者组消费一些消息,并且一些消息被另一个消费组消费;不,我希望2个组消耗消息,就好像另一个组不存在一样。Kafka:多个独立消费者群体可以消费一个主题吗?

回答

1

是的,多个消费者/消费者组可以独立使用来自主题的消息。每个消费者(或消费者群体)的抵消额分开保存。您可以运行kafka.tools.ConsumerOffsetChecker可以查看任何主题的任何消费群的偏移量如下图所示:

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic test --zookeeper localhost:2181 --group testgroup 

注意(这抵消),其中消费者开始读取从主题的消息被自动控制.offset.reset配置。如果设置为最小,则新消费者将从主题的开头(最小)开始或从主题的末尾开始(如果这被设置为最大)。

2

是的,单独的消费群体是完全独立的,所以他们都看到所有消息。

资源分区(主题/分区)只发生在组内。

+0

我不确定我是否理解“资源分区(主题/分区)只在组内发生”。每个主题的分区和复制不能改变每个消费者组;这是您创建主题本身时决定的。 – user1888243

+0

我的意思是将分区分配给消费者,因为在一个组中只能将一个消费者分配给一个分区。 –

相关问题