kafka之協調者

一、消費者加入消費組 1、加入組請求的業務邏輯主要步驟如下:    (1)、消費者加入消費組之前,需要做一些準備工作,比如同步提交一次偏移量,執行監聽器的回調。    (2)、消費者創建「加入組請求」,包括消費者的元數據作爲請求的數據內容。    (3)、消費者發送「加入組請求」,採用組合模式返回一個新的異步請求對象,並定義回調處理器。    (4)、客戶端通過輪詢,確保組合模式返回的異步請求必須
相關文章
相關標籤/搜索