检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
group 是 String Group ID。 topic 否 String 消息所属Topic。 client_id 是 String 客户端ID。 msg_id_list 否 Array of strings 消息列表。 响应参数 状态码: 200 表3 响应Body参数 参数
"available_zones": [ "effdcxxxxxx2f56533" ], "product_id": "c6.4u8g.cluster", "storage_spec_code": "dms.physical.storage.high.v2", "broker_num":
rocketmq.4u8g.cluster.small 1 ~ 10 300 ~ 30000 15000 2000 2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 60000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10
消费并发度 客户端的消费并发度由单客户端线程数和客户端数量决定。单客户端线程数是指单个客户端所包含的线程数量,客户端数量是指消费组所包含的客户端(消费者)数量。对于普通消息、定时/延时消息、事务消息及顺序消息的消费并发度计算方法如下: 消息类型 消费并发度 普通消息 单客户端线程数 *
x支持两种实例类型:基础版、专业版,它们的差异如表2所示。 表2 基础版和专业版的差异 维度 基础版 专业版 目标用户 入门级、对于成本敏感的用户。 对于可靠性、性能等要求高的进阶型、企业级用户。 产品定位 兼容开源的RocketMQ,提供基础的RocketMQ能力。 除了提供基础版能力外,还
参数 参数类型 描述 trace Array of trace objects 消息轨迹列表。 表4 trace 参数 参数类型 描述 success Boolean 是否成功。 trace_type String 轨迹类型 timestamp Number 时间。 group_name
收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖:
标签管理服务是一种快速便捷将标签集中管理的可视化服务,提供跨区域、跨服务的集中标签管理和资源分类功能。 为RocketMQ实例添加标签,可以方便用户识别和管理拥有的实例资源。
2024年3月 序号 功能名称 功能描述 阶段 1 计费系统的RocketMQ规格名称优化 在计费系统中优化RocketMQ实例的规格名称,便于用户使用和理解。优化后的规格名称为:分布式消息服务RocketMQ专享规格。 原有RocketMQ实例的规格名称容易与其他云服务或者规格的名称混淆,从而产生误解。
"name" : "broker-1" }, { "name" : "broker-2" } ], "result" : "success" } 状态码 状态码 描述 200 操作成功。 错误码 请参见错误码。 父主题: 实例管理
objects 产品详情列表。 表3 ProductEntity 参数 参数类型 描述 type String 产品类型,single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code
objects 产品详情列表。 表4 ProductEntity 参数 参数类型 描述 type String 产品类型,single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code
ClientData 参数 参数类型 描述 language String 客户端语言。 version String 客户端版本。 client_id String 客户端ID。 client_addr String 客户端地址。 subscriptions Array of Subscription
message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } } err = p.Shutdown() if err !=
在调用接口的时候,部分URL中需要填入项目ID(project_id),所以需要先在管理控制台上获取到项目ID。 项目ID获取步骤如下: 登录管理控制台。 鼠标悬停在右上角的用户名,选择下拉列表中的“我的凭证”。 在“API凭证”页面的项目列表中查看项目ID。 图1 查看项目ID 父主题: 附录
"value" : "7F00000123DC6E0BE85808B037820000" }, { "name" : "CLUSTER", "value" : "DmsCluster" }, { "name" : "TAGS",
B6835", "error_code" : "DMS.00000000", "error_message" : "Success." } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 重发死信消息。 1 2 3 4
期到期后仍未续费,资源状态变为“已冻结”。 超过宽限期仍未续费将进入保留期,如果保留期内仍未续费,资源将被自动删除。 华为云根据客户等级定义了不同客户的宽限期和保留期时长。 在RocketMQ实例到期前均可开通自动续费,到期前7日凌晨3:00首次尝试自动续费,如果扣款失败,每天凌
为什么查询到的消费组不在控制台中? 使用Admin Tool连接RocketMQ实例查询消费组信息时,会查出一些控制台中没有配置的消费组,如CID_ONSAPI_OWNER、SELF_TEST_C_GROUP、TOOLS_CONSUMER、CID_ONSAPI_PULL、CID_
在提交之后才投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 RocketMQ TCP协议的Python SDK只支持Linux系统。