检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RocketMQ是否支持自建Broker连接云上nameserver? 不支持。自建Broker连接到云上RocketMQ的nameserver,会影响管理面功能,导致查询不到Topic等问题。 父主题: 连接问题
认证证书 合规证书 华为云服务及平台通过了多项国内外权威机构(ISO/SOC/PCI等)的安全合规认证,用户可自行申请下载合规资质证书。 图1 合规证书下载 资源中心 华为云还提供以下资源来帮助用户满足合规性要求,具体请查看资源中心。 图2 资源中心 销售许可证&软件著作权证书
REGION>")) .build(); ListTopicAccessPolicyRequest request = new ListTopicAccessPolicyRequest(); request.withInstance
"4.8.0" ], "products" : [ { "type" : "cluster.small", "product_id" : "c6.4u8g.cluster.small", "ecs_flavor_id" : "c6.xlarge.2",
# 设置权限(角色名和密钥) producer.set_session_credentials( "ACL_ACCESS_KEY", # 角色名称 "ACL_SECRET_KEY", # 角色密钥 '' )#用
producer.WithCredentials(primitive.Credentials{ AccessKey: os.Getenv("ACL_ACCESS_KEY"), //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放
ACL_ACCESS_KEY", "ACL_SECRET_KEY")); TransactionMQProducer producer = new TransactionMQProducer("ProducerGroupName", rpcHook); ACL_ACCESS_KE
重启RocketMQ实例的Broker节点 分布式消息服务RocketMQ版控制台支持重启实例的某个Broker节点,或者所有Broker节点。 主节点重启过程中,客户端的生产和消费请求会被拒绝,持续时间不超过30s,建议在业务量少时重启节点。重启备节点,不会影响业务的使用。 怎么判断哪个是主节点?
WhiteRemoteAddress: &whiteRemoteAddressUser, SecretKey: &secretKeyUser, AccessKey: &accessKeyUser, } response, err := client.CreateUser(request) if err
认证鉴权 调用接口有如下两种认证方式,您可以选择其中一种进行认证鉴权。 AK/SK认证:通过AK(Access Key ID)/SK(Secret Access Key)加密调用请求。推荐使用AK/SK认证,其安全性比Token认证要高。 Token认证:通过Token认证调用请求。
规格:rocketmq.4u8g.cluster*1 总存储空间:高I/O,300GB 用了一段时间后,用户发现RocketMQ实例当前规格无法满足业务需要,于2023/03/20 9:00:00升配为rocketmq.8u16g.cluster*1。因为该RocketMQ实例打算长期使用下去,于2023/03/20
WhiteRemoteAddress: &whiteRemoteAddressUser, SecretKey: &secretKeyUser, AccessKey: &accessKeyUser, } response, err := client.UpdateUser(request) if err
生产者线程数:测试rocketmq.4u8g.cluster.small、rocketmq.4u8g.cluster和rocketmq.8u16g.cluster时,生产者线程数输入256,测试rocketmq.12u24g.cluster时,生产者线程数输入640。 消费命令: sh
15:50:04在“华北-北京四”区域购买了一个包年/包月4.8.0版本的RocketMQ实例(规格:rocketmq.4u8g.cluster.small*1,总存储空间:超高I/O 300GB),计费资源包括实例费用(代理规格和代理数量),以及存储空间费用(超高I/O 30
"rest_produce_success", "rest_produce_failed", "rest_produce_latency", "rest_produce_msg_num", "rest_produce_flow", "rest_consume_success", "rest_consume_failed"
RocketMQ_Topic_CreationSuccess 创建Topic失败 reliability RocketMQ_Topic_CreationFailure 修改Topic成功 reliability RocketMQ_Topic_ModifySuccess 修改Topic失败 reliability
ListConsumeGroupAccessPolicyRequest request = new ListConsumeGroupAccessPolicyRequest(); request.withEngine(ListConsumeGroupAccessPolicyRequest
String accessKey = System.getenv("ACL_ACCESS_KEY"); String secretKey = System.getenv("ACL_SECRET_KEY"); //ACL_ACCESS_KEY为用户
"192.168.xx.xx:8080" AccessKey = os.Getenv("ACL_ACCESS_KEY") SecretKey = os.Getenv("ACL_SECRET_KEY") ) //ACL_ACCESS_KEY为用户名,ACL_SECRET_
user_name 是 String 用户名。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 access_key String 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。 secret_key