-
RocketMQ是否支持自建Broker连接云上nameserver? - 分布式消息服务RocketMQ版
RocketMQ是否支持自建Broker连接云上nameserver? 不支持。自建Broker连接到云上RocketMQ的nameserver,会影响管理面功能,导致查询不到Topic等问题。 父主题: 连接问题
-
重启RocketMQ实例的Broker节点 - 分布式消息服务RocketMQ版
重启RocketMQ实例的Broker节点 操作场景 分布式消息服务RocketMQ版控制台支持重启实例的某个Broker节点,或者所有Broker节点。 主节点重启过程中,客户端的生产和消费请求会被拒绝,持续时间不超过30s,建议在业务量少时重启节点。
-
典型应用场景 - 分布式消息服务RocketMQ版
金融场景 相较于传统金融场景,互联网金融需要能及时响应互联网的快速变化。传统金融场景中共性的部分需要被抽取出来,进行细化为各个不同的微服务模块,构成基础的业务中台,基于业务中台提供的基本能力,用户可以在上层快速的构建多样的业务能力。
-
认证证书 - 分布式消息服务RocketMQ版
认证证书 合规证书 华为云服务及平台通过了多项国内外权威机构(ISO/SOC/PCI等)的安全合规认证,用户可自行申请下载合规资质证书。 图1 合规证书下载 资源中心 华为云还提供以下资源来帮助用户满足合规性要求,具体请查看资源中心。
-
收发普通消息 - 分布式消息服务RocketMQ版
main(String[] args) throws ClientException, InterruptedException, IOException { final ClientServiceProvider provider = ClientServiceProvider.loadService
-
修改用户参数 - 分布式消息服务RocketMQ版
Name: &nameGroupPerms, Perm: &permGroupPerms, }, } nameTopicPerms:= "topic1" permTopicPerms:= model.GetUserTopicPermsPermEnum
-
删除用户 - 分布式消息服务RocketMQ版
Build()) request := &model.DeleteUserRequest{} request.InstanceId = "{instance_id}" request.UserName = "{user_name}" response, err :=
-
查询用户详情 - 分布式消息服务RocketMQ版
group_perms Array of group_perms objects 特殊的消费组权限。 表3 topic_perms 参数 参数类型 描述 name String 主题名称。 perm String 权限。
-
修改消费组 - 分布式消息服务RocketMQ版
) print(e.error_msg) 修改consumer-group-test消费组的参数,最大重试次数修改为16。
-
与其他云服务的关系 - 分布式消息服务RocketMQ版
云监控(Cloud Eye) 云监控是一个开放性的监控平台,提供资源的实时监控、告警、通知等服务。
-
查询代理列表 - 分布式消息服务RocketMQ版
请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 brokers Array of brokers objects 代理列表。 表3 brokers 参数 参数类型 描述 ids Array of numbers 全部代理ID。
-
查询用户列表 - 分布式消息服务RocketMQ版
group_perms Array of group_perms objects 特殊的消费组权限。 表5 topic_perms 参数 参数类型 描述 name String 主题名称。 perm String 权限。
-
调用说明 - 分布式消息服务RocketMQ版
调用说明 分布式消息服务RocketMQ版提供了REST(Representational State Transfer)风格API,支持您通过HTTPS请求调用,调用方法请参见如何调用API。 父主题: 使用前必读
-
查看RocketMQ审计日志 - 分布式消息服务RocketMQ版
创建DMS实例订单成功 reliability createDMSInstanceOrderSuccess 创建DMS实例订单失败 reliability createDMSInstanceOrderFailure 提交修改DMS实例订单请求成功 reliability modifyDMSInstanceOrderSuccess
-
查询主题的消息数 - 分布式消息服务RocketMQ版
请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 max_offset Integer 最大偏移量。 min_offset Integer 最小偏移量。 brokers Array of brokers objects 代理。
-
查询实例的扩容规格列表 - 分布式消息服务RocketMQ版
max_consumer_per_broker String 每个节点的最大消费者数。 max_storage_per_node String 每个节点的最大存储。单位为GB min_broker String Broker的最小个数。
-
创建主题或批量删除主题 - 分布式消息服务RocketMQ版
(); listbodyBrokers.add("broker-0"); body.withPermission(CreateTopicOrBatchDeleteTopicReq.PermissionEnum.fromValue("all"));
-
消费验证 - 分布式消息服务RocketMQ版
error_code String 错误码。 error_message String 错误信息。 请求示例 消费验证。
-
使用ACL权限访问 - 分布式消息服务RocketMQ版
return msg def send_message_sync(): producer = Producer(gid) producer.set_name_server_address(name_srv) # 设置权限(角色名和密钥) producer.set_session_credentials
-
查询消息轨迹 - 分布式消息服务RocketMQ版
fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。