在遷移上雲或測試情境下,您可以開啟自由使用Group功能,通過代碼寫入直接建立Group,無需在控制台手動建立,協助您簡化操作,提升效率。
前提條件
您已購買並部署雲訊息佇列 Kafka 版執行個體,且該執行個體必須滿足以下條件:
專案 | 說明 |
狀態 | 服务中。 |
版本 | 大版本為2.2.0,且小版本為最新版本。 |
您可以在雲訊息佇列 Kafka 版控制台的实例详情頁面的基础信息地區查看執行個體的運行狀態和版本。
注意事項
在生產環境,長期開啟自由使用Group的功能,可能會由於用戶端使用不當出現資源隨意使用,導致營運成本增加,並且極易造成系統不穩定,建議您通過雲訊息佇列 Kafka 版控制台或者調用OpenAPI手動建立Group,進行統一管理。具體操作,請參見建立Group與CreateConsumerGroup。
操作步驟
登入雲訊息佇列 Kafka 版控制台,在概览頁面的资源分布地區,選擇地區。
在实例列表頁面,單擊目標執行個體名稱。
在配置信息地區,開啟自由使用 Group開關。
重要自由使用Group的名稱遵循Group的命名規則:
Group名稱長度限制為3~128個字元。
Group名稱只能包含字母、數字、短劃線(-)以及底線(_),且至少包含一個字母或數字。
自由使用的Group的數量需遵循雲訊息佇列 Kafka 版執行個體的規格限制,否則Group不能被自由使用。具體資訊,請參見使用限制。
在雲訊息佇列 Kafka 版控制台開啟自由使用Group的開關,在Group 管理頁面會顯示自由使用的Group,自動建立的Group的描述為Automatically created。
通過自由使用Group功能建立的Group, 會在控制台上Group 管理頁面顯示對應的Group資訊,自动创建欄標註為是。
開啟自由使用Group的開關表示雲訊息佇列 Kafka 版允許未在控制台建立的Group可以調用API進行訊息消費和位點提交等操作,如果關閉自由使用Group功能,那麼未在控制台建立的Group(即控制台上自動建立欄顯示為是的Group)將無法進行正常消費,請謹慎關閉。
開啟自由使用Group開關之後,您可以在消費端調用API來自由使用Group,範例程式碼如下:
props.put(ConsumerConfig.GROUP_ID_CONFIG, "newConsumerGroup"); consumer.subscribe(Collections.singletonList("newTopicName")); // 如果Group不存在,且符合規範,則自由使用。 consumer.poll(Duration.ofSeconds(1));
相關文檔
使用自動建立的Group訂閱Topic後,可在控制台查看Topic被訂閱的Group。具體操作,請參見查看Topic被訂閱的Group。
如果您希望使用控制台和API建立Group,請參見建立Group與CreateConsumerGroup。