揭祕kafka消費者三(再均衡監控器)

本篇文章介紹:再均衡監控器,從特定偏移量處開始處理記錄,退出,反序列化器,獨立消費者。 再均衡監控器 將在如下幾個方面介紹在均衡監控器: 定義:監聽失去分區所有權或獲取分區所有權; 方案:通過subscribe()方法進行監聽。參數:ConsumerRebalanceListener實例; ConsumerRebalanceListener:需要實現兩個方法 3.1:onPartitionsRev
相關文章
相關標籤/搜索