-
查询主题的消息数 - 分布式消息服务RocketMQ版
查询主题的消息数 功能介绍 查询主题的消息数。 调用方法 请参见如何调用API。
-
修改RocketMQ Topic配置 - 分布式消息服务RocketMQ版
读队列个数:Topic读数据可用的总队列数。 写队列个数:Topic写数据可用的总队列数。 创建Topic时未关联所有代理,单击“添加关联代理”,将Topic分布到其他代理上,并设置读队列个数和写队列个数。 修改完成后,单击“确定”。 父主题: Topic管理
-
创建主题或批量删除主题 - 分布式消息服务RocketMQ版
请求示例 4.8.0版本RocketMQ实例创建一个主题,关联的代理为broker-0,队列数为3。
-
监控安全风险 - 分布式消息服务RocketMQ版
用户可以实时掌握实例的各类业务请求、资源占用、流量、连接数和消息积压等关键信息。 关于DMS for RocketMQ支持的监控指标,以及如何创建监控告警规则等内容,请参见支持的监控指标。 父主题: 安全
-
产品规格 - 分布式消息服务RocketMQ版
产品规格 分布式消息服务RocketMQ版兼容开源RocketMQ 4.8.0和5.x,具体产品规格如下。 分布式消息服务RocketMQ版4.8.0 分布式消息服务RocketMQ版4.8.0产品规格由以下六个维度定义: 资源规格:定义使用的弹性云服务器的规格类型。 代理个数:定义实例的规模
-
实现订阅关系一致 - 分布式消息服务RocketMQ版
消费原理 RocketMQ为每个Topic划分了消息队列(Queue),队列数越大消费的并发度越大。一个消费组表示一个消费者群组,在分布式应用场景下,同一个消费组中的多个消费者共同完成Topic所有Queue的消费。
-
RocketMQ相关概念 - 分布式消息服务RocketMQ版
队列数越大消费的并发度越大。 生产者(Producer) 消息写入的触发者,负责将消息推送到服务端。 生产者组(Producer Group) 同一类生产者的集合,这类生产者发送同一类消息且发送逻辑一致。 消费者(Consumer) 接收消息的对象,负责从服务端获取消息。
-
消息堆积处理建议 - 分布式消息服务RocketMQ版
对于普通消息、定时/延时消息、事务消息及顺序消息的消费并发度计算方法如下: 消息类型 消费并发度 普通消息 单客户端线程数 * 客户端数 定时/延时消息 事务消息 顺序消息 Min(单客户端线程数 * 客户端数,队列数) 单客户端线程数的调整需谨慎,不能盲目调大线程数,如果设置过大的线程数反而会带来大量的线程切换开销
-
RocketMQ支持的监控指标 - 分布式消息服务RocketMQ版
消息消费数 实例一分钟被消费的消息数 单位:Count >0 RocketMQ实例 1分钟 current_topics 主题数 实例的主题数量 单位:Count 说明: 2022年5月16号及以后购买的实例,支持此监控项。
-
查看RocketMQ监控指标 - 分布式消息服务RocketMQ版
例如,在“节点”页签中,只需要展示“消息生产数”和“消息消费数”,请按照如下步骤操作。 在“节点”页签下,单击“设置”,弹出“设置”页面。 勾选“消息生产数”和“消息消费数”,单击“确定”。 监控指标设置成功后,选中监控指标,并拖动到需要展示的位置,完成监控指标的排序。
-
测试4.8.0版本RocketMQ实例性能 - 分布式消息服务RocketMQ版
消息大小:1KB 生产者线程数:测试rocketmq.4u8g.cluster.small、rocketmq.4u8g.cluster和rocketmq.8u16g.cluster时,生产者线程数输入256,测试rocketmq.12u24g.cluster时,生产者线程数输入640
-
Topic管理 - 分布式消息服务RocketMQ版
Topic管理 创建主题或批量删除主题 查询主题列表 删除指定主题 查询单个主题 修改主题 查询主题消费组列表 查询主题的消息数 父主题: API V2(推荐)
-
创建实例 - 分布式消息服务RocketMQ版
c6.4u8g.cluster.small:单个代理最大Topic数2000,单个代理最大消费组数2000 c6.4u8g.cluster:单个代理最大Topic数4000,单个代理最大消费组数4000 c6.8u16g.cluster:单个代理最大Topic数8000,单个代理最大消费组数
-
测试5.x版本RocketMQ实例性能 - 分布式消息服务RocketMQ版
消息大小:1KB 生产者线程数:256 消费命令: sh consumer.sh -n "${连接地址}" -t ${Topic名称} -g ${消费组名称} 连接地址:购买RocketMQ实例后,获取实例的连接地址。 Topic名称:创建Topic时设置的Topic名称。
-
API概览 - 分布式消息服务RocketMQ版
Topic管理 包括创建主题、删除主题、查询主题、修改主题、查询主题消费组列表、查询主题的消息数。 消息管理 包括查询消息、查询消息轨迹、导出死信消息、重发死信消息、消费验证。
-
查看RocketMQ Topic详情 - 分布式消息服务RocketMQ版
在详情页下方可以查看Topic中消息总数、已删除的消息数,以及消费组消费此Topic的情况。 图1 Topic详情(RocketMQ实例4.8.0版本) 图2 Topic详情(RocketMQ实例5.x版本) 父主题: Topic管理
-
变更RocketMQ实例规格 - 分布式消息服务RocketMQ版
例如扩容前实例的代理数为1,每个代理的磁盘大小为300GB,扩容后实例的代理数为2,此时代理的磁盘大小依旧为300GB,但是总磁盘大小为600GB。 rocketmq.4u8g.cluster.small规格不支持扩容代理规格。
-
查询消费列表或详情 - 分布式消息服务RocketMQ版
lag Long 消费堆积总数 max_offset Long 消息总数 consumer_offset Long 已消费消息数 brokers Array of Brokers objects Topic关联代理(当查询topic消费“详情”才显示此参数)。
-
权限和授权项 - 分布式消息服务RocketMQ版
topics/{topic} dms:instance:modify √ √ 查询主题消费组列表 GET /v2/{project_id}/instances/{instance_id}/topics/{topic}/groups dms:instance:get √ √ 查询主题的消息数
-
错误码 - 分布式消息服务RocketMQ版
Kafka实例创建Topic的分区数必须在1-20范围内。