在遷移上云或測試場景下,您可以開啟自由使用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。