检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
available brokers. 创建Topic的副本数大于当前可用的Broker数。 请联系技术支持工程师协助解决。 400 DMS.00400867 Failed to create the Smart Connect task. 创建connector task失败 请联系技术支持。
本文介绍了分布式消息服务RocketMQ版各特性版本的功能发布和对应的文档动态,欢迎体验。 2024年3月 序号 功能名称 功能描述 阶段 1 计费系统的RocketMQ规格名称优化 在计费系统中优化RocketMQ实例的规格名称,便于用户使用和理解。优化后的规格名称为:分布式消息服务RocketMQ专享规格。
RocketMQ业务使用流程 创建用户并授权使用DMS for RocketMQ 创建IAM用户,并授予DMS for RocketMQ的权限,以达到用户之间权限的隔离。 购买RocketMQ实例 RocketMQ实例采用物理隔离的方式部署,租户独占RocketMQ实例。 创建RocketMQ
云审计服务支持的分布式消息服务RocketMQ版操作列表 操作名称 资源类型 事件名称 创建Topic成功 reliability RocketMQ_Topic_CreationSuccess 创建Topic失败 reliability RocketMQ_Topic_CreationFailure
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
当网络发生异常或节点故障时,通过Raft协议自动切换主备关系,保持数据一致性。 - 数据持久化 业务系统日常运行中可能出现一些小概率的异常事件。部分可靠性要求非常高的业务系统,除了要求实例高可用,还要求数据安全、可恢复,以便在实例发生异常后能够使用备份数据进行恢复,保障业务正常运行。
rGroupName", rpcHook); ACL_ACCESS_KEY为用户名,ACL_SECRET_KEY为用户的密钥。创建用户的步骤,请参见创建用户。为了确保用户名和密钥的安全性,建议对用户名和密钥进行加密处理。 消费者增加用户认证信息 消费者初始化时需要增加“rpcHo
groups Array of ConsumerGroup objects 消费组列表。 max Integer 最大可创建消费组数量。 remaining Integer 剩余可创建消费组数量。 next_offset Integer 下个分页的offset。 previous_offset
rocketmqInstance表示RocketMQ实例配额。 tags表示标签的配额。 quota Integer 租户最大可以创建的实例个数,或者每个实例最大可以创建的标签个数。 used Integer 已创建的实例个数。 请求示例 GET https://{endpoint}/v1.0/{project_id}/quotas/dms
0,获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq
配置Topic 创建RocketMQ Topic Topic管理
应用示例 批量创建Topic
存储容量:定义单个代理可以保存的存储容量。 单个代理TPS:定义单个代理的TPS性能。 单个代理Topic数上限:定义单个代理可以创建的Topic数量。 单个代理消费组数上限:定义单个代理可以创建的消费组数量。 分布式消息服务RocketMQ版4.8.0支持的产品规格如表1所示。 TPS(Transaction
setNamesrvAddr("192.168.0.1:8100"); //producer.setUseTLS(true); //创建实例时,如果开启了SSL,请增加此行代码。 producer.setTransactionListener(transactionListener);
实例管理类接口 创建实例 查询实例 查询实例列表 修改实例 删除实例 父主题: API V1
Topic问题 支持多少个Topic? 是否支持自动创建Topic? Topic名称的命名规则是什么?
管理消费组 创建RocketMQ消费组 查看RocketMQ消费组详情 查看RocketMQ消费者连接地址 修改RocketMQ消费组配置 重置RocketMQ消费进度 删除RocketMQ消费组
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
RocketMQ的消息保留时间是多少?可以修改吗? RocketMQ支持的最大消息大小是多少?可以修改吗? RocketMQ副本存储形式是怎样的?可以修改吗? 消息创建时间在哪设置?
生命周期管理 查询所有实例列表 创建实例 查询指定实例 删除指定的实例 修改实例信息 批量删除实例 查询代理列表 父主题: API V2(推荐)