国际阿里云最新消息-国际阿里云最新消息文档介绍内容-阿里云

如何在控制台管理Consumer的offset？

提交消费位点的机制取决于您使用的客户端SDK，一般支持以下两种机制：自动提交：按照时间间隔，SDK把消费过的最新消息的位点+1提交上去。手动提交：应用程序里，把消费过的最新消息的位点+1提交上去。您可在控制台的 Group 管理页面，找到...

重置消费位点

云消息队列 RocketMQ 版支持以下方式重置消费位点：从最新位点开始消费消费者消费指定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 最近消费的...

开通短信服务并自定义签名

国内消息国际/港澳台消息在弹出的新页面中，单击添加签名来添加短信的签名。为了签名审核顺利通过，请您遵守签名规范。签名添加成功后，显示在签名列表中，请耐心等待审核。选择模板管理页签，添加短信的模板。单击添加模板。配置...

查看最新监控消息

您可以查看最新监控消息的基本信息、实例详情、日志和历史状态，帮助用户掌握每个监控节点的最新状态、任务日志和历史状态分布情况。本文介绍如何查看最新监控消息。前提条件已开启监控任务，具体操作，请参见开启监控任务。背景信息以...

查看最新监控消息

您可以查看最新监控消息的基本信息、实例详情、日志和历史状态，帮助用户掌握每个监控节点的最新状态、任务日志和历史状态分布情况。本文介绍如何查看最新监控消息。前提条件已开启监控任务，具体操作，请参见开启监控任务。背景信息以...

消费进度管理

重置功能云消息队列 RocketMQ 版的重置消费位点提供以下能力：从最新位点开始消费 Group ID消费指定Topic中的消息时，会跳过当前堆积（未被消费）的所有消息，从重置操作时间后发送的最新消息开始消费。从指定时间的位点开始消费：消费者...

为什么查询到的消息创建时间与设置的消息查询时间点...

可能原因设置的查询时间点小于当前分区最小位点的消息发送时间，或者超出当前分区最大位点的消息发送时间，此时会触发重置消费位点机制，查询到的消息创建时间为当前分区最新位点消息的发送时间。如果查询到的消息创建时间为空值，...

域名其他信息修改

修改国际域名注册信息域名信息如出现变更或错误信息需及时进行修改，如未及时更新可能导致域名被删除，您可参见如下内容操作国际域名信息变更。域名信息变更或错误需及时更新根据国际互联网域名与地址管理机构（ICANN）的规定和域名...

Subscription

订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略...

Subscription

订阅者通过Subscribe接口创建订阅，消息服务MNS 根据订阅的描述给用户端推送消息，推送的起点是订阅时Topic中最新的消息。订阅创建成功后，消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用，消息服务MNS 会按照指定的重试策略...

集成短信服务SMS

您可以登录短息服务控制台，在左侧导航栏，选择国内消息或国际/港澳台消息，然后在签名管理页签获取。说明必须是已添加、并通过审核的短信签名。更多短信签名规范，请参见短信签名规范。阿里云 templateCode 是短信模板Code。您...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC...

作为Input接入

步骤一：获取接入信息 Logstash通过云消息队列 Kafka 版的接入点与云消息队列 Kafka 版建立连接，并通过用户名及密码进行校验。登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择地域。在实例列表页面，单击作为...

如何处理消息堆积

问题现象在使用云消息队列 ...针对某些特殊业务场景，如果消息堆积已经影响到业务运行，且堆积的消息本身可以跳过不消费，您可以通过重置消费位点跳过这些堆积的消息从最新位点开始消费，快速恢复业务。具体操作，请参见重置消费位点。

功能与特性概述

消息类型对比消息类型是否支持可靠同步发送是否支持可靠异步发送是否支持Oneway发送是否支持多线程发送性能普通消息是是是是最高事务消息定时和延时消息分区顺序消息是否否否高全局顺序消息一般消息特性消息重试：...