新建消費組
更新時間 2025-04-16 14:10:46
最近更新時間: 2025-04-16 14:10:46
分享文章
介紹分布式消息服務Kafka的新建消費組功能操作介紹。
場景描述
Kafka新建消費組的場景如下:
- 多個應用程序需要獨立消費同一個主題:如果有多個應用程序需要從同一個Kafka主題中獨立消費消息,并且每個應用程序需要管理自己的消費進度和分區分配,那么可以為每個應用程序創建一個獨立的消費組。
- 消費者需要實現消息的負載均衡:當有多個消費者需要消費同一個主題的消息時,可以將它們加入同一個消費組,Kafka會自動將主題的分區均勻地分配給消費組中的消費者,實現消息的負載均衡。
- 消費者需要實現消息的并行處理:如果需要將一個主題的消息并行地處理,可以創建多個消費者實例,并將它們加入同一個消費組。Kafka會將主題的分區分配給消費組中的消費者,每個消費者只消費自己被分配的分區,從而實現消息的并行處理。
- 消費者需要實現高可用性:為了提高消費者的可用性,可以創建一個消費組,并將多個消費者實例加入該組。當一個消費者實例發生故障時,Kafka會將該消費者的分區重新分配給其他健康的消費者,從而保證消息的連續消費。
操作步驟
(1)登錄管理控制臺。
(2)進入Kafka管理控制臺。
(3)在實例列表頁在操作列,目標實例行點擊“管理”。
(4)點擊“消費組管理”后進入消費組管理頁面。
(5)點擊“創建消費組”后,輸入消費組名稱,點擊創建。
說明消費組業務應用接入使用時客戶端也可自動創建。
批量創建消費組
針對新建消費組數量較多情景,提供批量創建消費組功能。
(1)登錄管理控制臺。
(2)進入Kafka管理控制臺。
(3)在實例列表頁在操作列,目標實例行點擊“管理”。
(4)點擊“消費組管理”后、點擊“導入消費組”。
(5)點擊“導入消費組”后,出現如下界面,下載模板完成修改后,即可上傳完成導入。
模板如下。
表:參數說明。
| 參數 | 說明 |
|---|---|
| consumer group name | 消費組名稱。 |
| description | 描述 |