消息的偏移量和顺序消费原理
消息的偏移量
消息的发送⽅会把消息发送到broker中,broker会存储消息,消息是按照发送的顺序进⾏存储。因此消费者在消费消息时可以指明主题中消息的偏移量。默认情况下,是从最后⼀个消息的下⼀个偏移量开始消费。
顺序消费原理
- ⽣产者将消息发送给broker,broker会将消息保存在本地的⽇志⽂件中
/usr/local/kafka/data/kafka-logs/主题-分区/00000000.log
- 消息的保存是有序的,通过offset偏移量来描述消息的有序性
- 消费者消费消息时也是通过offset来描述当前要消费的那条消息的位置