kafka的工做原理分析(二)

1、消费者消费消息offset存储 kafka的全部消息都是持久化存储在broker上的,消费者每次消费消息是如何知道获取哪一条呢?kafka提供一个专门的tipic存储每一个consumer group的消费消息的offset,offset保证消息在分区内部有序,因此每次消费者均可以知道本身要从哪一条消息开始消费。__consumer_offsets_* 的一个topic ,把 offset 信
相关文章
相关标签/搜索