检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
开启RocketMQ ACL访问 通过ACL（Access Control List）可以实现对RocketMQ实例中生产者和消费者身份的精确识别，达到权限管理的目的。开启ACL权限控制功能后，生产消息和消费消息时，需要鉴权。 约束与限制 仅2021年8月21号后购买的实例，支持设置ACL访问控制。
RocketMQ实例规格。 c6.4u8g.cluster.small：单个代理最大Topic数2000，单个代理最大消费组数2000 c6.4u8g.cluster：单个代理最大Topic数4000，单个代理最大消费组数4000 c6.8u16g.cluster：单个代理最大Topic数8000，单个代理最大消费组数8000
消息查询的方法：按Group查询、按Message ID查询和按Message Key查询。 按Group查询：查询某时间段内指定消费组下所有的死信消息。此方法属于范围查询，查询到的死信消息可能比较多。 按Message ID查询：查询指定消费组下指定Message ID的消息。
4u8g.cluster*1，并在9:30:00升配为rocketmq.8u16g.cluster*1，那么在9:00:00 ~ 10:00:00间会产生两条计费信息。 第一条对应9:00:00 ~ 9:30:00，实例规格按照rocketmq.4u8g.cluster*1计费。
参数 参数类型 描述 trace Array of trace objects 消息轨迹列表。 表4 trace 参数 参数类型 描述 success Boolean 是否成功。 trace_type String 轨迹类型 timestamp Number 时间。 group_name
public void onSuccess(SendResult result) { // 消息发送成功。 System.out.println("send message success. msgId= "
险，建议在配置文件或者环境变量中密文存放,使用时解密。创建实例时，如果开启了ACL才需要添加以下代码。 String accessKey = System.getenv("ROCKETMQ_AK"); String secretKey = System
险，建议在配置文件或者环境变量中密文存放,使用时解密。创建实例时，如果开启了ACL才需要添加以下代码。 String accessKey = System.getenv("ROCKETMQ_AK"); String secretKey = System
dynamic.modify.enable,kafka.new.pod.port,feature.physerver.kafka.topic.modify,message_trace_enable,features.pod.token.access,kafka.ssl.cert.modify.enable
"name" : "broker-1" }, { "name" : "broker-2" } ], "result" : "success" } 状态码 状态码 描述 200 操作成功。 错误码 请参见错误码。 父主题： 实例管理
Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } err = p.Shutdown() if err != nil
objects 产品详情列表。 表3 ProductEntity 参数 参数类型 描述 type String 产品类型，single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code
objects 产品详情列表。 表4 ProductEntity 参数 参数类型 描述 type String 产品类型，single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code
body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS def start_consume_message(): consumer = PushConsumer('consumer_group')
"enabled": true, "pwd_status": false, "access_mode": "default", "is_domain_owner": false, "xuser_id":
切换协议。只能切换到更高级的协议。 例如，切换到HTTP的新版本协议。 200 OK 请求成功。 201 Created 创建类的请求完全成功。 202 Accepted 已经接受请求，但未处理完成。 203 Non-Authoritative Information 非授权信息，请求成功。 204
getName(), msgs); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); consumer.start(); System
B6835", "error_code" : "DMS.00000000", "error_message" : "Success." } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 消费验证。 1 2 3 4 5
京四”区域购买了一个包年/包月RocketMQ实例（rocketmq.4u8g.cluster*1），购买时长为1个月，计划在2023/04/18变更规格为rocketmq.8u16g.cluster*1。旧配置价格为6300 元/月，新配置价格为12150 元/月。计算公式如下：
"value" : "7F00000123DC6E0BE85808B037820000" }, { "name" : "CLUSTER", "value" : "DmsCluster" }, { "name" : "TAGS",
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
