检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
格名称，便于用户使用和理解。优化后的规格名称为：分布式消息服务RocketMQ专享规格。 原有RocketMQ实例的规格名称容易与其他云服务或者规格的名称混淆，从而产生误解。 本次仅优化展示的规格名称，实际的计费项和费用并没有发生改变，不会影响现有实例运行和使用。 商用
开启RocketMQ实例弹性TPS功能 当您遇到突发流量高峰的场景时，可以开启实例的弹性TPS功能。 仅5.x专业版支持开启弹性TPS功能。 前提条件 已购买RocketMQ 5.x专业版实例。 开启弹性TPS功能 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
对于同一个实例，Key值唯一。 长度为1~128个字符（中文也可以输入128个字符）。 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符（中文也可以输入255个字符）。 由任意语种字母、数字、空格和字符组成，字符仅支持_
消费验证是将消息重新发送到指定的在线客户端，验证消费者能否收到消息。消费验证会导致消息重复消费。 前提条件 仅在实例的“状态”为“运行中”时，才可以进行消费验证。 确保待进行消费验证的客户端处于在线状态，且消费者已订阅待重新发送的消息所属的Topic。 验证RocketMQ消息消费 登录管理控制台。
正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制，消息老化时间修改后，正常消息的保留时间和死信消息的保留时间都会被修改。 实例创建后，您可以根据业务需要修改消息老化时间。修改老化时间，不会重启实例。消息老化时间默认为48小时。 前提条件 已购买RocketMQ实例。 修改RocketMQ消息保留时间
将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org
对于同一个实例，Key值唯一。 长度为1~128个字符（中文也可以输入128个字符）。 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @ 首尾字符不能为空格。 value 否 String 标签值。 长度为0~255个字符（中文也可以输入255个字符）。 由任意语种字母、数字、空格和字符组成，字符仅支持_
消费组名称。 请求参数 无 响应参数 状态码： 200 表2 响应Body参数 参数 参数类型 描述 enabled Boolean 是否可以消费。 broadcast Boolean 是否广播。 brokers Array of strings 关联的代理列表。 name String
previous_offset Integer 上个分页的offset。 表4 ConsumerGroup 参数 参数类型 描述 enabled Boolean 是否可以消费。 broadcast Boolean 是否广播。 brokers Array of strings 关联的代理列表。 name String
是 String 消费组名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 enabled 是 Boolean 是否可以消费。 broadcast 是 Boolean 是否广播。 brokers 否 Array of strings 关联的代理列表。 name
x版本支持gRPC协议，4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费，并非在消费代码中设置，顺序消费消息的代码与普通消费的代码相同。
Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK") ) func main() { os
是否广播。 retry_max_time 否 Integer 最大重试次数，取值范围为1~16。 enabled 否 Boolean 是否可以消费。 consume_orderly 否 Boolean 是否按顺序消费（仅RocketMQ实例5.x版本需要填写此参数）。 group_desc
DMS for RocketMQ提供跨AZ类型实例，支持跨AZ容灾，当一个AZ异常时，不影响RocketMQ实例持续提供服务。 AZ内实例容灾 使用一主两备架构，备节点通过数据同步的方式保持数据一致。当节点故障时，通过Raft协议自动切换主备关系，保持数据强一致性。 数据容灾 通过支持数据多副本方式实现数据容灾。
x专业版时，如果开启弹性TPS功能，则会按照超过实例基础规格TPS上限的增量部分进行计费。 取值为计费周期即1小时内，增量部分TPS的最大值。 按量付费（先使用后付费） 与实例本身为按需或包年/包月无关。 每小时弹性TPS费用 = 1小时内增量部分TPS最大值 * 弹性TPS单价 计费示例 以包年
描述 type String 实例类型。 product_id String 产品ID。 ecs_flavor_id String 该产品使用的ECS规格。 billing_code String 账单计费类型。 arch_types Array of strings 支持的CPU架构类型。
队列ID。 timestamp_offset Long 重置消费进度。 请求示例 重置topic_01主题的消费进度到指定时间点。 POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/group
String 实例ID。 group 是 String 消费组名称。 请求参数 无 响应参数 无 请求示例 删除指定的消费组。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/{group}
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 无 请求示例 删除指定的实例。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id} 响应示例 无 SDK代码示例
String 实例ID。 topic 是 String 主题名称。 请求参数 无 响应参数 无 请求示例 删除指定的主题。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
