5、分區消費模型和組消費模型

一、分區消費模型 分區消費模型： 4個分區4個消費者實例，如圖所示，一個分區對應一個消費者。 步驟： 1、獲取分區數個數 2、爲每一個分區創建一個消費線程或進程，對應一個消費者實例 3、每一個消費者實例工作內容： （1）創建kafka實例的連接（主機名和端口） （2）指定消費者參數（對應topic的哪個partition分區） （3）設置消費的偏移量（主題的某分區的哪個偏移量號開始-每條消息對應一

>>阅读原文<<