自由使用Group特别适用于测试场景或临时迁移上云场景,无需手动重复创建Group,极大地简化了操作,提升效率。

前提条件

您已购买并部署消息队列Kafka版实例,且该实例必须满足以下条件:
项目 说明
状态 服务中
版本 大版本为2.2.0,且小版本为最新版本。
说明 您可以在消息队列Kafka版控制台的实例详情页面的基础信息区域查看实例的运行状态和版本。

背景信息

自由使用Group是指当消息队列Kafka版实例发送请求以获取不存在的Group元数据时,例如使用不存在的Group订阅消息,消息队列Kafka版实例可以自由使用Group

注意事项

在生产环境,长期开启自由使用Group的功能,可能会因为客户端使用不当而出现资源随意使用的问题,运维起来极其麻烦,极易造成系统不稳定,建议您通过消息队列Kafka版控制台或者调用OpenAPI手动创建Group,进行统一管理。具体操作,请参见创建GroupCreateConsumerGroup

操作步骤

  1. 登录消息队列Kafka版控制台
  2. 概览页面的资源分布区域,选择地域。
  3. 实例列表页面,单击目标实例名称。
  4. 实例详情页面的配置信息区域,打开自由使用 Group开关。
    注意
    • 自由使用Group的名称遵循消息队列Kafka版Group命名规则:
      • Group名称长度限制为3~128个字符。
      • Group名称只能包含字母、数字、短划线(-)以及下划线(_),且至少包含一个字母或数字。
    • 自由使用的Group的数量需遵循消息队列Kafka版实例的规格限制,否则Group不能被自由使用。具体信息,请参见使用限制
    • 消息队列Kafka版控制台仅打开自由使用Group的开关,在Group 管理页面并不会显示自由使用的Group
    • 打开自由使用Group的开关仅表示消息队列Kafka版允许控制台不存在的名称符合要求的Group可以调用API进行消息消费和位点提交等操作,如果关闭自由使用Group功能,控制台不存在的Group都无法进行正常消费。
    开启自由使用Group开关之后,您可以在消费端调用API来自由使用Group,示例代码如下:
    props.put(ConsumerConfig.GROUP_ID_CONFIG, "newConsumerGroup");
    consumer.subscribe(Collections.singletonList("newTopicName"));
    // 如果Group不存在,且符合规范,则自由使用。
    consumer.poll(Duration.ofSeconds(1));
    Topic 详情页面的订阅关系页签,查看Topic被订阅的Group。具体操作,请参见查看Topic被订阅的Group
    说明 通过自由使用Group功能使用的Group, 不会在控制台上显示对应的Group信息,Group信息需要您手动创建。