kafka-02-kafka設計原理詳解

一、  消費者消費消息的offset記錄機制 每個consumer會定期將自己消費分區的offset提交給kafka內部topic： __consumer_offsets ，提交過去的時候， key是consumerGroupId+topic+分區號，value就是當前offset的值 ，kafka會定期清理topic裏的消息，最後就保留最新的那條數據 因爲__consumer_offsets可能

>>阅读原文<<