Kafka是否支持不同消费者读取同一个partition但offset不同?
Does Kafka supports different consumers reads the same partition with different offsets?
Kafka是否支持不同的消费者读取同一个分区不同的offset?
一个分区:
|------------Consumer 2, offset 2
+---+---+---+---+----+
| 0 | 1 | 2 | 3 | .. | <---- a particular partition
+---+---+---+---+----+
|______Consumer 1, offset 1
Is it possible?
更新(来自官方Kafka):
不可以,对于一个主题中的一个分区,一次只有一个消费者可以读取该分区。一旦读取了这些消息,分配给该主题的下一个消费者将读取下一个尚未提交的偏移量。
您可以使用 --from-beginning
配置消费者,以便下一个消费者可以读取该分区中的所有消息。
当然可以。从图中可以看出,C1
和C3
正在消耗P0
。也许 C1
读了 10 条消息而 C3
读了 5 条。唯一重要的是 C1
和 C3
不在同一个消费者组中。同一组的两个消费者不能消费同一个分区。
Kafka是否支持不同的消费者读取同一个分区不同的offset?
一个分区:
|------------Consumer 2, offset 2
+---+---+---+---+----+
| 0 | 1 | 2 | 3 | .. | <---- a particular partition
+---+---+---+---+----+
|______Consumer 1, offset 1
Is it possible?
更新(来自官方Kafka):
不可以,对于一个主题中的一个分区,一次只有一个消费者可以读取该分区。一旦读取了这些消息,分配给该主题的下一个消费者将读取下一个尚未提交的偏移量。
您可以使用 --from-beginning
配置消费者,以便下一个消费者可以读取该分区中的所有消息。
当然可以。从图中可以看出,C1
和C3
正在消耗P0
。也许 C1
读了 10 条消息而 C3
读了 5 条。唯一重要的是 C1
和 C3
不在同一个消费者组中。同一组的两个消费者不能消费同一个分区。