检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
支持多少个消费组个数? 更多 远程登录 应用容器化改造介绍 应用容器化改造流程 步骤1:对应用进行分析 步骤2:准备应用运行环境 更多 云服务器卡顿 应用容器化改造介绍 应用容器化改造流程 步骤1:对应用进行分析 步骤2:准备应用运行环境 更多 操作系统相关 应用容器化改造介绍 应用容器化改造流程
游业务来不及处理的情况,进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码,以保障系统的稳定。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 使用Maven方式引入依赖。 <dependency> <groupId>org
broker_connections 连接数 虚拟机使用的连接数 单位:Count 说明: 2022年5月16号及以后购买的实例,支持此监控项。 >=0 RocketMQ实例节点 1分钟 broker_cpu_usage CPU使用率 虚拟机的CPU使用率 单位:% 说明: 20
收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式
送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 收发普通消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version
为什么查询到的消费组不在控制台中? 使用Admin Tool连接RocketMQ实例查询消费组信息时,会查出一些控制台中没有配置的消费组,如CID_ONSAPI_OWNER、SELF_TEST_C_GROUP、TOOLS_CONSUMER、CID_ONSAPI_PULL、CID_
购买RocketMQ实例【视频】 连接RocketMQ实例 开源RocketMQ客户端向RocketMQ实例生产消息和消费消息前,需要先连接RocketMQ实例。 购买RocketMQ实例时,加密方式支持配置为SSL。 支持区域: 全部 连接未开启SSL的RocketMQ实例 连接已开启SSL的RocketMQ实例
投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。
String grpc连接地址(仅RocketMQ 5.x版本会显示此字段)。 grpc_domain_name String grpc连接域名(仅RocketMQ 5.x版本会显示此字段)。 public_grpc_address String 公网grpc连接地址(仅RocketMQ
的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4
在实例列表页面的“规格”中查看扩容后的代理个数。 扩容代理个数前,需确认安全组已放通的网段和实例对外提供的端口信息,否则可能造成客户端无法连接新扩容的业务节点,从而导致消息生产失败。其中,放通的网段为实例所在子网网段,放通的端口范围为10100~(10100+3n-1)(n表示代理数量)。 已开启
当“任务状态”为“迁移完成”,表示所有元数据都已成功迁移。 当“任务状态”为“迁移失败”,表示元数据中部分或全部元数据迁移失败。单击迁移任务名称,进入迁移任务详情页,在“迁移结果”中查看迁移失败的Topic/消费组名称,以及失败原因及解决方法。解决问题后,再执行后面的步骤。 迁移生产消息至分布式消息服务RocketMQ版实例。
String grpc连接地址(仅RocketMQ 5.x版本会显示此字段)。 grpc_domain_name String grpc连接域名(仅RocketMQ 5.x版本会显示此字段)。 public_grpc_address String 公网grpc连接地址(仅RocketMQ
次请求的结果,供您查询、审计和回溯使用。 弹性云服务器(Elastic Cloud Server) 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计算组件。RocketMQ实例运行在弹性云服务器上,一个代理对应三台弹性云服务器。 云硬盘(Elastic Volume Service)
0版本的RocketMQ实例,规格配置如下: 规格:rocketmq.4u8g.cluster*1 总存储空间:高I/O,300GB 用了一段时间后,用户发现RocketMQ实例当前规格无法满足业务需要,于2023/03/20 9:00:00升配为rocketmq.8u16g.clus
到回查后重新发送事务提交或回滚。消息只有在提交之后才投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version
创建Topic的数量 Topic的数量根据产品规格确定,不支持修改。 当Topic的数量达到上限后,您无法继续创建Topic。 是否支持自动创建Topic 不支持。 代理故障场景 实例中部分代理故障时,无法创建、修改和删除Topic,只能查询Topic。 消费组 表3 消费组约束与限制 限制项
请求什么类型的操作。 GET:请求服务器返回指定资源。 PUT:请求服务器更新指定资源。 POST:请求服务器新增资源或执行特殊操作。 DELETE:请求服务器删除指定资源,如删除对象等。 HEAD:请求服务器资源头部。 PATCH:请求服务器更新资源的部分内容。当资源不存在的时
异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 以下示例仅介绍同步发送的示例代码。 收发普通消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 在命令行输入python,检查是否已安装Python。得到如下回显,说明Python已安装。 Python
操作影响 RocketMQ实例修改接入方式会存在如表1所示的影响。 部分存量RocketMQ实例不支持“PERMISSIVE”,具体以控制台显示为准。 表1 修改接入方式的影响 服务端接入方式 影响 PLAINTEXT > SSL 存量实例会重启,业务会中断,需要在客户端修改实例接入方式。