Skip to content

Latest commit

 

History

History
21 lines (14 loc) · 646 Bytes

3.offset.md

File metadata and controls

21 lines (14 loc) · 646 Bytes

Kafka 消费位移

无法查找消费位移

  • 默认从分区末尾开始消费
  • 可以指定从开始或者末尾开始消费

指定消费位移

  • seek 指定 offset
  • offsetfortimes 查找指定时间的位移

保证消息的顺序消费

  • 生产者通过消息 key 生产消息,确保同一个 key 的消息保存在同一个分区上
  • 消费者角度,kafka 保证一个分区只能被一个消费者消费