检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
PushConsumer, ConsumeStatus def callback(msg): print(msg.id, msg.body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS
PushConsumer, ConsumeStatus def callback(msg): print(msg.id, msg.body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS
{ "resend_results" : [ { "msg_id" : "C0A8149E0000277600000000000B6835", "error_code" : "DMS.00000000", "error_message" : "Success
请联系技术支持 400 DMS.00400128 Invalid public access parameters. 公网访问参数错误。
"KEYS", "value" : "" }, { "name" : "UNIQ_KEY", "value" : "7F00000123DC6E0BE85808B037820000" }, { "name" : "CLUSTER
{ "resend_results" : [ { "msg_id" : "C0A8149E0000277600000000000B6835", "error_code" : "DMS.00000000", "error_message" : "Success
System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); return ConsumeOrderlyStatus.SUCCESS
message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections,rabbitmq.manage.support,replica_port_standalone
= nil { fmt.Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } err = p.Shutdown
= nil { fmt.Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } } time.Sleep
rocketmq.4u8g.cluster.small规格不支持扩容代理规格。 前提条件 已创建RocketMQ实例，且实例状态为“运行中”。 变更实例规格 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
为什么查询到的消费组不在控制台中？ 使用Admin Tool连接RocketMQ实例查询消费组信息时，会查出一些控制台中没有配置的消费组，如CID_ONSAPI_OWNER、SELF_TEST_C_GROUP、TOOLS_CONSUMER、CID_ONSAPI_PULL、CID_ONSAPI_PERMISSION
删除用户 功能介绍 删除用户。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/users/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
服务韧性 DMS for RocketMQ提供了3级可靠性架构，通过跨AZ容灾、AZ内实例容灾、实例数据多副本技术方案，保障服务的持久性和可靠性。 表1 DMS for RocketMQ可靠性架构 可靠性方案 简要说明 跨AZ容灾 DMS for RocketMQ提供跨AZ类型实例
{ "results" : [ { "result" : "success", "instance" : "019cacb7-4ff0-4d3c-9f33-f5f7b7fdc0e6" } ] } SDK代码示例 SDK代码示例如下。
修改消费组 功能介绍 修改指定消费组参数。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
>=0 RocketMQ实例节点 1分钟 broker_produce_success_rate 生产成功率 节点所有生产请求的成功率 单位：% 说明： 2022年5月16号及以后购买的实例，支持此监控项。
查询代理列表 功能介绍 查询代理列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/brokers 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID
您需要有RocketMQ的管理员权限“DMS FullAccess”，具体操作请参考创建用户并授权使用DMS for RocketMQ。 创建VPC和子网。 创建的VPC与RocketMQ实例必须在相同的区域。
查询主题的消息数 功能介绍 查询主题的消息数。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/topics/{topic}/status 表1 路径参数 参数 是否必选 参数类型 描述 project_id
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
