Kafka消費者詳解

Kafka採用消費組保證了「一個分區只可被消費組中的一個消費者所消費」  消費者組再平衡實現故障容錯 一旦有消費者加入或退出消費組，導致消費組成員列表發生變化，消費組中所有的消費者就要執行再平衡（rebalance） 工作。如果訂閱主題的分區有變化，所有的消費者也都要再平衡。 由於消費者消費消息的最小單元是分區，因此每個分區都應該記錄消費進度，而且消費進度應該面向消費組級別。 消費者除了需要保存消

>>阅读原文<<