kafka是否支持不同的使用者以不同的偏移量读取同一分区?
分区:
|------------Consumer 2, offset 2
+---+---+---+---+----+
| 0 | 1 | 2 | 3 | .. | <---- a particular partition
+---+---+---+---+----+
|______Consumer 1, offset 1
Is it possible?
更新(来自官方Kafka):
kafka是否支持不同的使用者以不同的偏移量读取同一分区?
分区:
|------------Consumer 2, offset 2
+---+---+---+---+----+
| 0 | 1 | 2 | 3 | .. | <---- a particular partition
+---+---+---+---+----+
|______Consumer 1, offset 1
Is it possible?
更新(来自官方Kafka):
2条答案
按热度按时间ddrv8njm1#
不,对于主题中的分区,一次只有一个使用者可以读取该分区。一旦这些消息被读取,分配给该主题的下一个消费者将读取下一个尚未提交的偏移量。
您可以使用
--from-beginning
以便下一个使用者可以读取该分区中的所有消息。bbmckpt72#
当然。正如你从照片上看到的
C1
以及C3
正在消耗P0
. 也许 吧C1
阅读10条信息C3
读5。唯一重要的是C1
以及C3
不属于同一消费群体。来自同一组的两个使用者不能使用同一分区。