查看最新监控消息
您可以查看最新监控消息的基本信息、实例详情、日志和历史状态，帮助用户掌握每个监控节点的最新状态、任务日志和历史状态分布情况。本文介绍如何查看最新监控消息。前提条件 已开启监控任务，具体操作，请参见 开启监控任务。背景信息 以...
查看最新监控消息
您可以查看最新监控消息的基本信息、实例详情、日志和历史状态，帮助用户掌握每个监控节点的最新状态、任务日志和历史状态分布情况。本文介绍如何查看最新监控消息。前提条件 已开启监控任务，具体操作，请参见 开启监控任务。背景信息 以...
QueryMqSofamqConsumerTimespan
查询指定的 Group ID 订阅的 Topic 的最新消息时间戳以及消费的最新时间。可以查询某个 Topic 当前服务器上存在的消息的最新时间和最早时间，以及查询消费端最近消费的时间。本接口一般用于展示消费进度的概况，与 ...
如何在控制台管理Consumer的offset？
提交消费位点的机制取决于您使用的客户端SDK，一般支持以下两种机制：自动提交：按照时间间隔，SDK把消费过的最新消息的位点+1提交上去。手动提交：应用程序里，把消费过的最新消息的位点+1提交上去。您可在控制台的 Group 管理 页面，找到...
重置消费位点
云消息队列 RocketMQ 版 支持以下方式重置消费位点：从最新位点开始消费 消费者消费指定Topic中的消息时，会跳过当前堆积（未被消费）的所有消息，从重置操作时间后发送的最新消息开始消费。从指定时间点的位点开始消费 消费者将从重置时间...
消费进度管理
重置功能 云消息队列 RocketMQ 版 的重置消费位点提供以下能力：从最新位点开始消费 Group ID消费指定Topic中的消息时，会跳过当前堆积（未被消费）的所有消息，从重置操作时间后发送的最新消息开始消费。从指定时间的位点开始消费：消费者...
集群消费和广播消费
由客户端维护 出现重复消费的概率稍大于集群模式，客户端每次重启都会从最新消息消费。设置集群消费和广播消费 云消息队列 RocketMQ 版 的消费方式支持在消费者客户端修改，您需要在订阅消息的SDK代码中设置相关参数。若未设置，则默认使用...
使用云消息队列 Kafka 版时出现消息堆积
说明客户端一直在拉取最新消息，没有消息堆积，属于正常情况。说明 消息堆积量会根据消息量、消费端位点提交频率的变化而变化，数值大并不一定表示堆积。例如，某个Topic的发送频率为10000 tps，消费端位点提交频率为1 s提交1次，正常情况...
查看消费状态
说明客户端一直在拉取最新消息，没有消息堆积，属于正常情况。堆积量逐步扩大，并且消息位点一直不变。客户端的消费线程因为某些原因卡住，没有继续消费，也没有继续向服务端提交位点，属于异常情况，即消息的确堆积了。堆积量逐步扩大，...
OnsConsumerResetOffset-重置Group ID消费位点
该 Group ID 在消费该 Topic 下的消息时会跳过当前堆积（未被消费）的所有消息，从这之后发送的最新消息开始消费。对于程序返回"reconsumeLater"，即走重试流程的这部分消息来说，清除无效。1：清理到指定时间。请指定一个时间点，这个时间...
全球消息路由
消息延迟 当前同步到的位点和最新消息位点之间的时间差。消息堆积量 当前还没有来得及同步的消息数量。最新同步时间 最近一次消息同步发生的时间。编辑过滤规则 说明 编辑过滤规则，需先停止任务。在 基础信息 区域的 过滤规则 一栏，单击...
ResetConsumeOffset-重置消费位点
Group ID 消费指定 Topic 中的消息时，会跳过当前堆积（未被消费）的所有消息，从重置操作时间后发送的最新消息开始消费。SPECIFIED_TIME：从指定时间的位点开始消费。消费者将从重置时间对应的消费位点之后的消息进行消费，不管这些消息...
基本概念
最大位点 分区的最大位点，即当前分区的最新消息的位点。如何查看当前分区的最大位点，请参见 查看分区状态。消费位点 分区被当前Consumer消费了的消息的最大位点。如何查看消费位点，请参见 查看消费状态。最近消费时间 Group 最近消费的...
更新记录
本文为您介绍ChatApp消息服务文档更新的最新动态，基于此您可以及时了解ChatApp消息服务的新增特性及功能变更。2023年11月更新记录 时间 特性 内容描述 2023.11.21 新增 控制台-目录管理，增加商品目录授权按钮用于授权Meta商品目录。控制...
为什么查询到的消息创建时间与设置的消息查询时间点...
可能原因 设置的查询时间点小于当前分区最小位点的消息发送时间，或者超出当前分区最大位点的消息发送时间，此时会触发重置消费位点机制，查询到的 消息创建时间 为当前分区最新位点消息的发送时间。如果查询到的 消息创建时间 为空值，...
Subscription
订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略...
Subscription
订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略...
作为Input接入
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
作为Input接入
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
功能与特性概述
重置消费位点：根据时间或位点重置消费进度，允许用户进行消息回溯或者跳过堆积的消息从最新位点消费。死信队列：将无法正常消费的消息储存到特殊的死信队列供后续处理。仪表盘：提供丰富、全面、多维度的统计指标，您可以分别从实例、...
如何处理消息堆积
问题现象 在使用 云消息队列 ...针对某些特殊业务场景，如果消息堆积已经影响到业务运行，且堆积的消息本身可以跳过不消费，您可以通过重置消费位点跳过这些堆积的消息从最新位点开始消费，快速恢复业务。具体操作，请参见 重置消费位点。
如何快速测试云消息队列 Kafka 版服务端是否正常？
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
步骤三：创建资源
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
作为Output接入
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
作为Output接入
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
作为Input接入
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
作为Input接入
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
作为Output接入
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
作为Output接入
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
将云消息队列 Kafka 版接入阿里云Elasticsearch
Log Compaction清理策略保证相同Key的消息，最新的value值一定会被保留。主要适用于系统宕机后恢复状态，系统重启后重新加载缓存等场景。例如，在使用Kafka Connect或Confluent Schema Registry时，需要使用Kafka Compact Topic存储系统...
队列（MessageQueue）
队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...
基本概念
消费位点（ConsumerOffset）一条消息被某个消费者消费完成后不会立即从队列中删除，云消息队列 RocketMQ 版 会基于每个消费者分组记录消费过的最新一条消息的位点，即消费位点。更多信息，请参见 消费进度管理。消息索引（MessageKey）消息...
OnsTopicStatus-查询Topic状态
取值说明如下：2：可以发布 4：可以订阅 6：可以发布和订阅 6 LastTimeStamp long 当前 Topic 内最新一条消息的就绪时间，如果 Topic 内没有消息，则该参数返回值为 0。该参数值的格式为毫秒级 Unix 时间戳。就绪消息及就绪时间具体含义，...
OnsConsumerTimeSpan-查询Topic可重置时间范围
test-mq_topic MinTimeStamp long 整个 Topic 目前最新存储的消息的生产时间。1570701231122 InstanceId string 需查询的消费端 Group ID 所对应的实例 ID。MQ_INST_111111111111_DOxxxxxx 示例 正常返回示例 JSON 格式 {"RequestId":"A07E...
函数计算
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
消息服务MNS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 消息服务MNS 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已创建 消息服务MNS 队列。具体步骤，...
云消息队列 Kafka 版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 云消息队列 Kafka 版 中的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
云消息队列 RocketMQ 版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将其他数据源中的数据快速导入 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。创建...
云消息队列 RocketMQ 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 RocketMQ 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
消息队列Kafka版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买并部署 云消息队列 ...
- 产品推荐
- 这些文档可能帮助您