kafka-02-kafka設計原理詳解

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