kafka获取offset流程
时间: 2023-10-25 07:08:19 浏览: 83
kafka客户端offset
好的,关于kafka获取offset的流程,我可以给你一些解析。首先,Kafka会将每个分区的消息偏移量存储在内部topic中,称为__consumer_offsets。每个消费者都会通过获取__consumer_offsets主题的偏移量来跟踪其读取的消息。当消费者拉取消息时,它首先会获取主题中的偏移量,然后拉取该偏移量后的所有消息。当消费者消耗消息时,它会将消费偏移量提交回Kafka,并且Kafka将更新__consumer_offsets主题。
希望对你有所帮助,如果还有其他问题可以继续问我。
阅读全文