Kafka的消费者从某个有副本的分区读取数据。在消费者确认后,偏移量被更新。是否更新了所有分区副本的偏移量?
偏移量只更新一个分区,而不是它的副本。假设我们有一个主题,我们有5个分区,RF为3,它正在被一个消费者消耗。
消费者将只连接到每个分区的一个副本来读取数据(默认情况下,它将连接到每5个分区的leader),一旦它从分区读取消息-偏移量将更新为每5个分区(不是每个分区的每个副本)。
不,不是所有Kafka副本的偏移量都是单一的。每个Kafka副本都有自己的偏移量,可以彼此不同。