检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RocketMQ是否支持自建Broker连接云上nameserver？ 不支持。自建Broker连接到云上RocketMQ的nameserver，会影响管理面功能，导致查询不到Topic等问题。 父主题： 连接问题
", "rest_produce_failed", "rest_produce_latency", "rest_produce_msg_num", "rest_produce_flow", "rest_consume_success", "rest_consume_failed",
重启RocketMQ实例的Broker节点 分布式消息服务RocketMQ版控制台支持重启实例的某个Broker节点，或者所有Broker节点。 主节点重启过程中，客户端的生产和消费请求会被拒绝，持续时间不超过30s，建议在业务量少时重启节点。重启备节点，不会影响业务的使用。 怎么判断哪个是主节点
{ "engine" : "rocketmq", "versions" : [ "4.8.0" ], "products" : [ { "type" : "cluster.small", "product_id" : "c6.4u8g.cluster.small
ACL_ACCESS_KEY：表示用户名。创建用户的步骤，请参见创建用户。 ACL_SECRET_KEY：表示用户的密钥。 事务消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。
AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。 Token认证：通过Token认证调用请求。
AccessKey：表示用户名。创建用户的步骤，请参见创建用户。 SecretKey：表示用户的密钥。 test：表示Topic名称。 父主题： Go（TCP协议）
("ProducerGroupName", rpcHook); ACL_ACCESS_KEY为用户名，ACL_SECRET_KEY为用户的密钥。
try { ListTopicAccessPolicyResponse response = client.listTopicAccessPolicy(request); System.out.println(response.toString
reliability RocketMQ_Group_ModifySuccess 编辑消费组失败 reliability RocketMQ_Group_ModifyFailure 删除消费组成功 reliability RocketMQ_Group_DeletionSuccess
String accessKey = System.getenv("ACL_ACCESS_KEY"); String secretKey = System.getenv("ACL_SECRET_KEY"); //ACL_ACCESS_KEY为用户名，
实例当前规格无法满足业务需要，于2023/03/20 9:00:00升配为rocketmq.8u16g.cluster*1。
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 access_key 否 String 用户名，只能英文字母开头，且由英文字母、数字、中划线、下划线组成，长度为7~64个字符。 secret_key 否 String 密钥。 8-32个字符。
消息大小：1KB 生产者线程数：测试rocketmq.4u8g.cluster.small、rocketmq.4u8g.cluster和rocketmq.8u16g.cluster时，生产者线程数输入256，测试rocketmq.12u24g.cluster时，生产者线程数输入640
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 access_key 否 String 用户名，只能英文字母开头，且由英文字母、数字、中划线、下划线组成，长度为7~64个字符。 secret_key 否 String 密钥。 8-32个字符。
Build()) request := &model.ListConsumeGroupAccessPolicyRequest{} request.Engine = model.GetListConsumeGroupAccessPolicyRequestEngineEnum
每小时弹性TPS费用 = 1小时内增量部分TPS最大值 * 弹性TPS单价 计费示例 以包年/包月计费模式为例，假设您于2023/03/08 15:50:04在“华北-北京四”区域购买了一个包年/包月4.8.0版本的RocketMQ实例（规格：rocketmq.4u8g.cluster.small
= os.Getenv("ACL_ACCESS_KEY") SecretKey = os.Getenv("ACL_SECRET_KEY") ) //ACL_ACCESS_KEY为用户名，ACL_SECRET_KEY为用户的密钥。
= os.Getenv("ACL_ACCESS_KEY") SecretKey = os.Getenv("ACL_SECRET_KEY") ) //ACL_ACCESS_KEY为用户名，ACL_SECRET_KEY为用户的密钥。
请求参数 无 响应参数 状态码： 200 表2 响应Body参数 参数 参数类型 描述 access_key String 用户名，只能英文字母开头，且由英文字母、数字、中划线、下划线组成，长度为7~64个字符。 secret_key String 密钥。 8-32个字符。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
