在迁移上云或测试场景下,您可以开启自由使用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。