消息队列RocketMQ版_消息队列RocketMQ版文档介绍内容-天翼云

消息堆积
介绍分布式消息服务Kafka消息堆积功能操作内容。场景描述 Kafka消息堆积的场景包括以下几个: 消费者处理延迟:当消费者的处理能力不足或出现故障时,无法及时消费Kafka中的消息,导致消息堆积。这可能是由于消费者的处理逻辑复杂、处理速度慢,或者消费者的资源不足等原因引起的。网络故障:当Kafka集群与消费者之间的网络出现故障或不稳定时,可能导致消息传输延迟或中断。这会导致消息在Kafka中堆积,等待网络恢复后才能被消费。

来自：
帮助文档
分布式消息服务Kafka
用户指南
消费组管理
消息堆积
消息管理
消息接收组点击【消息接收组】,可以查看、创建、管理消息接收组,一个消息接收组中支持配置企业微信机器人地址、钉钉订阅地址、多个邮箱及手机号,用于接收告警消息。所有接收组中的手机号,共享短信通知配额。

来自：
帮助文档
智能边缘云
运维与监控
消息管理
消息中心
消息中心页面提供防护容器的下线通知和删除服务通知,以便用户及时恢复防护容器。查看消息登录容器安全卫士控制台。在左侧导航栏,选择“消息中心”,进入消息中心页面。支持查看“服务信息”和“删除服务”类消息。标记已读在消息中心页面,阅读消息后,可以勾选多条消息后,单击“标记已读”,在弹出的对话框中,可以选择“全部标记已读”或只对当前选择项标记已读,选择完成后,单击“确认”。

来自：
帮助文档
容器安全卫士
用户指南
消息中心
创建用户
本章节介绍了如何创建分布式消息服务RocketMQ实例的用户。操作场景 RocketMQ实例支持ACL权限控制功能,通过创建多个用户并为其赋予不同的Topic和消费组权限,以达到用户之间的权限隔离。前提条件已购买RocketMQ实例。步骤一:开启ACL访问控制登录分布式消息服务RocketMQ控制台。单击RocketMQ实例的名称,进入实例详情页面。在“连接信息”区域,单击“ACL访问控制”后的,开启ACL访问控制。

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
用户管理
创建用户
查询指定时间段内订阅组内存在的死信消息
1rowsArray of Objects消息详情列表。rows表 rows参数参数类型说明示例下级对象queueIdInteger队列ID。0storeSizeInteger存储大小,单位B280queueOffsetInteger队列偏移量。0sysFlagInteger系统标记。0bornTimestampLong消息生成时间戳。1661947215767bornHostString消息生成主机地址。192.168.71.1:64222storeTimestampLong消息存储时间戳。

来自：
帮助文档
分布式消息服务RocketMQ
API参考
API
2022-04-06
死信队列管理
查询指定时间段内订阅组内存在的死信消息
生产消息
(6)在弹窗中,输入消息内容、消息条数等信息,点击确认即可发送。

来自：
帮助文档
分布式消息服务Kafka
用户指南
Topic管理
生产消息
消息订阅
本页介绍天翼云TeleDB数据库消息订阅。消息订阅可以对不同类型的消息进行订阅,选择需要的消息类型,保存后,订阅类型的消息会在触发时进行推送。

来自：
帮助文档
分布式融合数据库HTAP
私有云产品
管理平台使用手册
数据库资源与生命周期管理服务操作指南
消息中心
消息订阅
RocketMqProducer监控
clientIdclientId客户端实例标识-ENUMLASTgroup生产者组生产者组-ENUMLASTqueue消息队列消息队列标识-ENUMLASTpidpidpid-STRINGLASTconcurrentMax最大并发推送消息最大并发-INTMAXerrorCount错误次数推送消息的错误次数-INTSUMerrorTraceId错误traceId采集周期内发生错误的调用链对应的traceid-STRINGLASTinvokeCountinvokeCountPublish调用次数-INTSUMpublishedMsgCountpublishedMsgCount

来自：
帮助文档
应用性能管理
产品介绍
指标总览
消息队列
RocketMqProducer监控
步骤四：配置必须的监控告警
表1 RabbitMQ实例配置告警的指标指标名称告警策略指标说明解决方案内存高水位状态告警阈值:原始值=1连续触发次数:1告警级别:致命告...消息生产加快消费采用生产者确认的发送模式,并监控生产端消息生产速度和时长,当消息生产时长有明显增加时进行流控措施磁盘高水位状态告警阈值:原始值>=1连续触发次数:1告警级别:致命告警阈值为1表示触发磁盘高水位,会阻塞消息生产减少惰性队列的消息堆积减少持久化队列的消息堆积删除队列内存使用率告警阈值:原始值>业务预期使用率(推荐

来自：
帮助文档
分布式消息服务RabbitMQ
快速入门
步骤四：配置必须的监控告警
支持监控的服务列表
分布式消息服务Kafka版的监控指标分布式消息服务RoabbitMQ版的监控指标分布式消息服务RocketMQ版的监控指标数据库分类服务命名空间维度监控指标参考文档数据库关系型数据库SYS.RDS请参考右侧相关文档链接页面。

来自：
帮助文档
云监控服务
用户指南
支持监控的服务列表
管理类
RocketMQ实例是否支持扩容? 可以扩容。登录RocketMQ控制台,在包周期实例所在行,单击“更多 > 扩容”,即答完成实例的扩容。消费的最长保留时间是多久? 一般情况下消息如果未被消费会一直保留,只有被消费后,才会被删除。但是如果设置了过期时间(TTL),则以TTL时间为准。

来自：
帮助文档
分布式消息服务RocketMQ
常见问题
管理类
创建方式简介
创建实时数据流集群:实时数据流集群提供高效的流式计算、消息队列等组件能力,支持实时数据ETL和日志采集分析的业务需求。创建自定义集群:自定义集群提供丰富灵活的服务搭配,支持自行选择业务所需服务。

来自：
帮助文档
翼MapReduce
用户指南
配置集群
创建方式简介
变更实例规格
本章节介绍了如何变更分布式消息服务RocketMQ实例规格,以及扩容存储空间、扩容代理个数。操作场景 RocketMQ实例创建成功后,您可以根据业务需要,扩容存储空间和代理个数。不支持同时扩容存储空间和代理个数,如果需要可以分别进行扩容。当前只支持扩容,不支持缩容。扩容存储空间有次数限制,只能扩容20次。扩容代理个数,可以扩大总分区数。前提条件已创建RocketMQ实例,且实例状态为“运行中”。操作步骤登录分布式消息服务RocketMQ控制台。

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
实例管理
变更实例规格
查询产品规格
", "error":"ROCKETMQ_1201", "statusCode": "900" } 状态码请参考状态码错误码请参考错误码

来自：
帮助文档
分布式消息服务RocketMQ
API参考
API
2022-04-06
生命周期管理
查询产品规格
创建应用用户和密码
本文介绍分布式消息服务RocketMQ入门指引的创建应用用户和密码内容。背景信息新建消息实例后,必须新建应用用户,然后应用才能在此消息实例上发送、消费消息。应用用户:指MQ客户端,连接服务器生产消费时,需要进行权限校验,所以MQ客户端的用户,称为应用用户;除了用户密码的校验,还可以为用户指定topic,代表该用户只能生产消费指定的topic,其他topic不能生产消费。操作步骤 1、天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。

来自：
帮助文档
分布式消息服务RocketMQ
快速入门
创建应用用户和密码
编辑用户
本章节介绍了如何编辑分布式消息服务RocketMQ实例的用户。操作场景用户创建成功后,您可以根据业务需要修改以下用户信息:IP白名单、管理员、默认Topic权限、默认消费组权限和密钥。操作步骤登录分布式消息服务RocketMQ控制台。单击RocketMQ实例的名称,进入实例详情页面。在左侧导航栏,单击“用户管理”,进入“用户管理”页面。在待修改的用户所在行,单击“编辑”,弹出“编辑用户”对话框。根据业务需要,修改如表1所示信息。

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
用户管理
编辑用户
【通知】CTGMQ引擎调整为白名单特性
分布式消息服务RocketMQ引擎类型CTGMQ引擎调整为白名单特性,更多了解请查看快速入门-创建RocketMQ实例引擎类型说明。调整时间 2024年7月5日影响范围所有区域调整影响新用户默认不开放CTGMQ引擎订购开通,如需要该特性,请联系技术支持开通后使用。已购买CTGMQ引擎实例的用户,原实例仍可正常使用,续费、扩容等操作不受影响。

来自：
帮助文档
分布式消息服务RocketMQ
服务公告
2024年
【通知】CTGMQ引擎调整为白名单特性
查询实例列表
0:未启用,1:已启用0deleteWhenString清理时间配置4tpsLimitString集群级TPS限制值2500、5000max...队列数8表 LabelInfo参数参数类型说明示例下级对象labelIdString标签唯一标识IDc2f0324741f349feb2e557e3f09cce7fkeyString标签键RY-key-11856valueString标签值RY-val-11856枚举参数无请求示例请求urlhttps:

来自：
帮助文档
分布式消息服务RocketMQ
API参考
API
2022-04-06
实例管理
查询实例列表
操作类常见问题
升级Broker可能产生消息乱序、客户端连接中断、消息量不均衡等影响。升级Broker包含以下影响: 升级过程中,会逐个重启云消息队列 Kafka 版集群中所有的Broker。在重启Broker的过程中服务不会中断,但是从每个Broker重启完成之后的5分钟内消费的分区消息可能会发生乱序。重启过程中已有的客户端连接可能会中断。客户端要有自动重连功能,服务端的其他Broker会自动接替服务。

来自：
帮助文档
分布式消息服务Kafka
常见问题
操作类
操作类常见问题
弹性资源池队列管理
弹性资源池优先满足两个队列的最小CU,队列A先分配32CU,队列B分配64CU,剩余CU数为32CU:弹性资源池的最大CU-两个队列的最小CU之和=128-32-64=32CU。2. 因为两个队列的优先级相同,则剩余32CU随机分配给两个队列。弹性资源池扩缩容CU分配场景说明(有任务场景) 场景弹性资源池实际CUs队列A资源分配队列B资源分配弹性资源池CU数分配说明弹性资源池添加了两个队列,分别为队列A和队列B。

来自：
帮助文档
数据湖探索
用户指南
弹性资源池
弹性资源池基本操作
弹性资源池队列管理
事件目标概述
事件目标事件总线EventBridge支持以下事件目标:函数计算分布式消息服务RocketMQ分布式消息服务RabbitMQ分布式消息服务KafkaHTTP、HTTPS地址

来自：
帮助文档
事件总线
用户指南
事件总线
事件规则
事件目标
事件目标概述
弹性资源池添加队列
弹性资源池队列添加完成后,可以参考弹性资源池队列管理查看弹性资源池添加的所有队列配置和策略信息。

来自：
帮助文档
数据湖探索
用户指南
弹性资源池
弹性资源池基本操作
弹性资源池添加队列
标签管理
标签可以识别资源,您可以将作用相同的分布式消息服务RocketMQ资源通过标签进行归类,便于搜索和资源聚合。本文介绍标签的使用说明以及标签的相关操作。使用说明标签都由一对键值对(Key-Value)组成。资源的任一标签的标签键(Key)必须唯一。例如,实例先添加了type:order标签,后续如需添加type:pay标签,需先删除type:pay标签。添加标签登录分布式消息服务RocketMQ控制台,在左侧导航栏单击实例列表。在顶部菜单栏,选择地域,如华东1。

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
实例管理
标签管理
应用场景
结合消息队列Kafka、Logstash对日志数据进行采集清洗,进入Elasticsearch或OpenSearch中存储检索分析,并通过Kibana或Dashboards进行可视化呈现。高稳定:通过读写限流、查询熔断、集群监控等方式保障。性能优化:通过支持压缩算法、内核增强节省存储空间,增强读写速率、降低响应延迟。易用性:支持多种统计分析方法、划分维度,丰富的可视化查询,可对接BI实现拖拽式报表。

来自：
帮助文档
云搜索服务
产品介绍
应用场景
产品组件
支持文件、数据库、消息队列等多种数据源采集支持灵活的数据处理,如字段提取、数据脱敏等内置健康检查机制,支持通过API或可视化界面监控数据管道运行状态CerebroCerebro 是一个功能强大且易于使用的云搜索服务管理工具,适合开发、运维和数据分析等多种场景。通过Cerebro可以对实例进行Web可视化管理,如监控实时的磁盘、集群负载、内存使用率等,通过其直观的界面和丰富的功能,用户可以更高效地管理和监控云搜索实例。云搜索服务兼容开源Cerebro,适配0.9.4。

来自：
帮助文档
云搜索服务
产品介绍
产品组件
Kafka业务迁移
异步通信和消息队列:Kafka作为消息队列,可以用于异步通信和解耦系统之间的依赖关系。通过将同步的请求和响应转换为异步的消息,可以提高系统的可伸缩性和响应性能,实现松耦合的系统架构。日志收集和分析:Kafka可以用作日志收集和分析的中间件,用于接收和传递系统和应用程序的日志数据。通过将日志数据发送到Kafka中,可以实现日志的集中存储和分发。同时,可以使用Kafka的消费者来实时消费和分析日志数据,帮助进行故障排查、性能监控和安全审计等工作。

来自：
帮助文档
分布式消息服务Kafka
最佳实践
Kafka业务迁移
服务内联委托
配置消息队列或事件总线等消息服务的访问权限,使用函数计算监听消息源的事件。当有新的消息或事件产生时,可以直接触发函数执行,实现事件驱动的计算模型。配置日志服务相关权限,允许自动收集函数执行日志,便于日志的搜索、分析和可视化展示,帮助用户快速定位问题。

来自：
帮助文档
函数计算
安全与合规
IAM访问控制
服务内联委托
消息中心
用户想要查看或管理站内消息时,通过用户中心的进行管理。

来自：
帮助文档
新手村
帮助服务
消息中心
消息广播
Kafka 自身没有消息广播的语义,可以通过创建不同的 Consumer Group 来模拟实现。

来自：
帮助文档
分布式消息服务Kafka
最佳实践
消费者实践
消息广播
响应消息头
本章主要介绍响应消息头。调用API时,API网关增加如下响应消息头。 X-Apig-Mode: debug表示响应消息头增加API网关调试信息。

来自：
帮助文档
API网关
调用API网关
调用已发布的API
响应消息头
功能特性
云工作流目前支持比较常见的触发器场景: 定时触发器、HTTP触发器、消息队列类型(Kafka、 RokectMQ)触发器, 云原生网关触发器工作流调度简介特性功能标准(Standard)模式云工作流支持创建标准(Standard)和快速(Express)两种模式的工作流。标准(Standard)模式适用于传统意义上的离线业务流程编排执行场景,具备执行步骤状态的持久化存储,支持运行长时间的工作流执行状态流转。

来自：
帮助文档
函数计算
用户指南
云工作流
功能简介
功能特性
消息过滤
Kafka 自身没有消息过滤的语义。实践中可以采取以下两个办法: 如果过滤的种类不多,可以采取多个 Topic 的方式达到过滤的目的; 如果过滤的种类多,则最好在客户端业务层面自行过滤。实践中请根据业务具体情况进行选择,也可以综合运用上面两种办法。

来自：
帮助文档
分布式消息服务Kafka
最佳实践
消费者实践
消息过滤

天翼云最新活动

12.12年度钜惠

爆款云主机2核2G仅需28.8元/年，X实例35.1元/半年起！ 8代机+XSSD新客专享2.5折！

免费体验DeepSeek，上天翼云息壤

新老用户均可免费体验2500万Tokens，限时两周

云上钜惠

爆款云主机全场特惠，更有万元锦鲤券等你来领！

算力套餐

让算力触手可及

天翼云AI产品特惠

人脸识别+文字识别焕新，新用户免费试用

中小企业服务商合作专区

国家云助力中小企业腾飞，高额上云补贴重磅上线

出海产品促销专区

爆款云主机低至2折，高性价比，不限新老速来抢购！

天翼云电脑专场

移动办公新选择，爆款4核8G畅享1年3.5折起，快来抢购！

息壤智算

应用商城

定价

合作伙伴

开发者

支持与服务

了解天翼云

天翼云最新活动

产品推荐

弹性云主机

物理机

一体化计算加速平台·异构计算

天翼云CTyunOS系统

应用托管

科研助手

一站式智算服务平台

知识库问答

人脸检测

推荐文档

JAVA API

关于天翼云

价格

登录

客户端下载安装

管理云间高速