检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
否 Number 总读队列个数。 write_queue_num 否 Number 总写队列个数。 permission 否 String 权限。 响应参数 状态码: 204 表3 响应Body参数 参数 参数类型 描述 - AnyType 操作成功。 请求示例 修改指定主题的参数
新增批量添加或删除实例标签、查询实例标签和查询项目标签接口。 2023-01-13 本次变更如下: 新增查询主题列表接口。 2022-07-07 本次变更如下: 新增权限和授权项章节。 2022-05-16 第一次正式发布。
最大重试次数,取值范围为1~16。 createdAt Long 创建时间戳。 permissions Array of strings 权限集。 consume_orderly Boolean 是否按顺序消费。 请求示例 GET https://{endpoint}/v2/{e
API概览 创建实例 创建主题或批量删除主题 常见问题 了解更多常见问题、案例和解决方案 热门案例 是否兼容RocketMQ? 当前实例可靠性是怎么保障的? 支持多少个Topic? 支持多少个消费组个数? 更多 远程登录 应用容器化改造介绍 应用容器化改造流程 步骤1:对应用进行分析 步骤2:准备应用运行环境
physical.storage.high.v2", "broker_num": 1 } name:实例名称,由您自行定义。 engine:消息引擎,设置为reliability。 engine_version:消息引擎的版本。 storage_space:消息存储空间,单位MB。具体取值范围,请参考创建实例。
A的消息,会把Tag A消息过滤掉,从而导致部分Tag A消息未被消费。 图1 错误的消费组设置 这种情况下,把消费者A和消费者B设置不同的消费组,即可解决消费混乱的问题。 图2 正确的消费者组设置
供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息: 全局顺序消息:对于指定的一个Topic,将队列数量设置为1,这个队列内所有消息按照严格的先入先出FIFO(First In First Out)的顺序进行发布和订阅。 分区顺序消息:对于指定的
供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息: 全局顺序消息:对于指定的一个Topic,将队列数量设置为1,这个队列内所有消息按照严格的先入先出FIFO(First In First Out)的顺序进行发布和订阅。 分区顺序消息:对于指定的
供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息: 全局顺序消息:对于指定的一个Topic,将队列数量设置为1,这个队列内所有消息按照严格的先入先出FIFO(First In First Out)的顺序进行发布和订阅。 分区顺序消息:对于指定的
配置RocketMQ实例的公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。当业务不再使用公网访问功能时,关闭实例的公网访问功能。 约束与限制 RocketMQ实例只支持绑定IPv4弹性IP地址。 前提条件 只有处于“运行中”状态
供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息: 全局顺序消息:对于指定的一个Topic,将队列数量设置为1,这个队列内所有消息按照严格的先入先出FIFO(First In First Out)的顺序进行发布和订阅。 分区顺序消息:对于指定的
供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息: 全局顺序消息:对于指定的一个Topic,将队列数量设置为1,这个队列内所有消息按照严格的先入先出FIFO(First In First Out)的顺序进行发布和订阅。 分区顺序消息:对于指定的
app_id String 应用ID。 app_name String 应用名称。 permissions Array of strings 权限。 请求示例 查询指定消费组的详细信息。 GET https://{endpoint}/v2/{project_id}/instances
Number 总读队列个数。 total_write_queue_num Number 总写队列个数。 permission String 权限。 brokers Array of brokers objects 关联的代理。 message_type String 消息类型(RocketMQ实例5
消息。 准备网络环境。 RocketMQ实例分内网地址以及公网地址两种网络连接方式。如果使用公网地址,则消息生产与消费客户端需要有公网访问权限,并配置如下安全组。 表1 安全组规则(RocketMQ实例4.8.0版本) 方向 协议 端口 源地址 说明 入方向 TCP 8200 R
进入“费用中心 > 续费管理”页面。 自定义查询条件。 可在“到期转按需项”页签查询已经设置到期转按需的资源。 可对“手动续费项”、“自动续费项”、“到期不续费项”页签的资源设置到期转按需的操作。 设置包年/包月资源到期后转按需。 单个资源到期转按需:选择需要更改计费模式的RocketMQ实例,单击操作列“更多
white_remote_address String IP白名单。 admin Boolean 是否为管理员。 perm String 权限。 请求示例 查询主题的授权用户列表。 GET https://{endpoint}/v2/{project_id}/instances/
例如,在“节点”页签中,只需要展示“消息生产数”和“消息消费数”,请按照如下步骤操作。 在“节点”页签下,单击“设置监控指标”,弹出“设置监控指标”页面。 勾选“消息生产数”和“消息消费数”,单击“确定”。 监控指标设置成功后,选中监控指标,并拖动到需要展示的位置,完成监控指标的排序。 父主题: 查看监控指标与配置告警
最大重试次数 设置消费失败的最大重试次数。 取值范围:1~16 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。 是否顺序消费 RocketMQ实例的版本为5.x时,需要设置此参数。
ID无法作为消息的唯一标识符。RocketMQ可以为消息设置Key,把业务的唯一标识作为消息的唯一标识,从而实现消息的幂等。为消息设置Key的示例代码如下: Message message = new Message(); message.setKey("Order_id"); // 设置消息的Key,可以使