当往Kafka Topic中写入数据提示...相关文档 如果消息超过 消息保留时长 还未被删除，具体原因，请参见 为什么消息已经过期还未被删除？当磁盘空间已满时，除了等待自动删除过期数据，也可以通过升配购买磁盘容量，详情请参见 升级实例配置。
什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是指Consumer重复消费某条消息时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生...
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
Endpoint 访问 消息服务MNS 的接入地址，登录 MNS控制台，单击右上角 获取Endpoint 查看。不同地域的接入地址不同。SecurityToken 阿里云访问控制服务提供的短期访问权限凭证，直接使用阿里云账号或者RAM用户访问不需要配置该项。更多信息...
功能原理 什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持消费者按照发送消息的先后顺序获取消息，从而实现业务场景中的顺序处理。相比其他类型消息，顺序消息在发送、存储和投递的处理过程中，更多强调多...
场景描述 本文首先介绍什么是实时数仓以及相关技术架构，接着介绍资讯聚合类业务的典型场景及其业务目标，并据此设计了相应的技术架构。然后介绍如何部署基础环境和搭建实时数仓，并介绍业务系统如何使用实时数仓。解决的问题 通过 云消息...
在线直播教育的场景通常会涉及多个直播间，且每个直播间中也会有多名成员。本文以单直播间、一名老师、两名学生的场景为例，说明如何使用 云消息队列 MQTT 版 实现直播...直播场景需要传输流媒体服务，详细信息，请参见 什么是音视频通信。
什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次，即使生产端重试消息发送导致某消息重复投递，该消息在消费端也只被消费一次。Exactly-Once语义是消息系统和流式计算系统中消息流转的最...
ChatApp 消息服务是阿里云为全球企业打造的一款高效触达用户的消息引擎，通过与WhatsApp平台合作，使您轻松地使用WhatsApp平台的消息服务，触达全球10亿+用户，通过丰富的消息类型，提升您与客户的互动体验，创造更大业务价值。
解决方案 方案介绍 适用场景 参考文档 架构可视化感知方案 Kubernetes集群中的业务是运行在节点组成的资源池上，使得定位Pod的调用链路以及拓扑关系非常复杂。如何以可视化的方式监控Kubernetes中的负载状态，以及更好地可视化集群中流量的...
本文介绍 云消息队列 MQTT 版 客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述 资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因 接入点格式不正确，正确...
容器服务ACK中使用容器运行应用的大致流程是什么？容器服务ACK与阿里云其他产品一起使用的推荐方案是什么？如何选择容器服务ACK的集群类型？如何规划集群容量？ECS服务器怎么选型？如何选择阿里云容器镜像服务ACR个人版和企业版？线上或线...
云消息队列 Kafka 版 没有处理失败消息的设计，实践中通常会打印失败的消息或者存储到某个服务（例如创建一个Topic专门用来放失败的消息），然后定时检查失败消息的情况，分析失败原因，根据情况处理。消费延迟 云消息队列 Kafka 版 的消费...
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
本文提供使用TCP协议下的社区版Java SDK收发事务消息的示例代码供您参考。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载4.5.2或以上版本的社区版 Java SDK。准备工作。获取阿里云访问...
升级Broker可能产生消息乱序、客户端连接中断、消息量不均衡等影响。升级Broker可能产生以下影响：升级过程中，会逐个重启 云消息队列 Kafka 版 集群中所有的Broker。在重启Broker的过程中服务不会中断，但是从每个Broker重启完成之后的5...
我重置消费位点跳过之前堆积的消息，为什么还有部分消息未被重置？目前重置消息功能对重试中消息不生效，因此重置后仍然可能会有少量重试消息投递。通过消费位点重置，最多能重新消费到多久以前的消息？选择从指定时间点重置时，可以选择的...
什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台，使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建，通过企业级功能扩展了Kafka的优势，同时消除了Kafka管理或...
为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送返回“Too many publishes in progress”错误。本地测试先发送消息，再订阅接收不到消息，设置离线消息...
本文介绍阿里云如何保证消息队列中的消息是安全的。消息服务MNS 提供了安全可靠的身份验证机制，确保您的队列受到保护，防止遭到未经授权的访问。只有阿里云账户拥有者才能访问其创建的队列。
MSE微服务治理发布企业版，助力企业构建完整微服务治理体系 2022-04-14 微服务治理技术白皮书 如今越来越多的企业使用微服务架构来开发业务应用，而业务发展离不开微服务治理的保驾护航。《微服务治理技术白皮书》着重分享如何借助于治理的...
自动创建Topic是指当 云消息队列 Kafka 版 实例发送请求以获取不存在的Topic元数据时，例如向不存在的Topic发送生产请求，云消息队列 Kafka 版 可以自动创建Topic。自动创建Topic适用于迁移上云场景或测试场景，无需手动重复创建Topic，...
云消息队列 RocketMQ 版（原名开放消息服务，简称ONS）是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。
客户端监听即将失效的Token信息（无需订阅）服务端为方便业务调试和监控，会在Token即将失效的时候以系统Topic的形式推送通知消息到MQTT客户端，客户端可以监控该消息来判断是否有出现过Token即将到期的情况。接收Topic：$SYS/...
客户端监听即将失效的Token信息（无需订阅）服务端为方便业务调试和监控，会在Token即将失效的时候以系统Topic的形式推送通知消息到MQTT客户端，客户端可以监控该消息来判断是否有出现过Token即将到期的情况。接收Topic：$SYS/...
更多信息，请参见 什么是云消息队列 Kafka 版。阿里云Elasticsearch Elasticsearch简称ES，是一个基于Lucene的实时分布式的搜索与分析引擎，是遵从Apache开源条款的一款开源产品，是当前主流的企业级搜索引擎。它提供了一个分布式服务，...
当Kafka出现消费堆积、倾斜、流量被限流等异常时，您可以查看Group和Topic之间的订阅关系，获取Topic各个分区的消费进度，了解消息的堆积总量，及时调整业务、预防风险。注意事项 建议一个消费组不要订阅超过三个Topic，避免消息堆积。当您...
消息服务MNS 规定了阿里云向客户提供的 消息服务MNS 的服务可用性等级指标及赔偿方案。如需查看 消息服务MNS 的服务可用性等级指标及赔偿方案，请参见 消息服务MNS服务等级协议。
例如网络抖动、服务端升级、管控平台升级维护、ECS宕机等情况，会大幅度增加创建Topic的耗时，业务的超时是固定的，必然因为超时，导致创建失败。业务冲突：自动创建Topic，容易触发不同业务名称冲突，如果触发，不同业务数据混合，很难...
阿里云消息服务MNS（Message Service）是一种高效、可靠、安全、便捷、可弹性扩展的分布式消息服务。MNS能够帮助应用开发者在他们应用的分布式组件上自由的传递数据、通知消息，构建松耦合系统。
本策略定义了管理消息服务（MNS）的权限。查看策略详情 AliyunMNSReadOnlyAccess 您可以将 AliyunMNSReadOnlyAccess 策略授权给RAM身份。本策略定义了只读访问消息服务（MNS）的权限。查看策略详情 授权操作参考 RAM 身份默认没有任何权限...
购买证书时选择不同的证书类型、域名类型、SSL证书品牌、服务，您需要支付的费用不同。在购买之前，建议您先了解产品的计费明细。本文介绍 数字证书管理服务 的计费明细以及SSL证书到期后的处理方法。计费方式 SSL证书 及其相关服务 采用预...
云消息队列 Kafka 版（ApsaraMQ for Kafka）秉持开放的原则拥抱开源，全面融合Kafka开源生态，做到无缝迁移，打造更安全、更可靠、更易运维的Kafka企业级消息服务。
消息服务MNS 的欠费说明如下：消息服务MNS 服务费用的计费周期为小时，即阿里云将在下一小时就您上一小时的服务使用进行计量、出具账单并自您的阿里云账户中按账单金额扣划服务费用。账单出账时间通常在当前计费周期结束后一小时内。当您的...
本文介绍如何使用 消息服务MNS。注册阿里云账号并开通 消息服务MNS 服务。登录 账号管理，在左侧导航栏单击 安全设置，在 安全设置 页面获取账号ID。登录 用户信息管理，在左侧导航栏单击 安全信息管理，在 安全信息管理 页面获取访问密钥...
前提条件 云消息队列 Kafka 版 实例的状态为 服务中。背景信息 升级大版本 升级大版本是指跨版本升级，例如将 云消息队列 Kafka 版 实例的版本从0.10.x版本升级至2.x版本。重要 目前新部署实例仅支持2.x版本，存量0.10.x可正常使用。由于2....
消息服务MNS 自2015年09月正式商业化至今，由于 消息服务MNS 计费项多，导致前期的财务预算以及后期的账目核算难度较高。因此 消息服务MNS 推出新版计费模型，已于2018年12月06日正式生效。详细信息，请参见 MNS计费调整通知。
计费相关 删除队列后，是否继续计费 删除主题后，是否继续计费 消息问题 消息服务MNS的订阅成功后收不到消息 删除消息时报“message not exist”的错误 HttpEndpoint接口接收不到消息 使用消息服务MNS的HTTPEndpoint接口时签名认证失败 ...
消息发送后您可以通过 Chat App 消息服务 控制台查看消息发送和接收详情、状态报告、批量发送详情等信息。本文为您介绍如何在 Chat App 消息服务 控制台查看消息发送和接收详情等操作。查看消息清单 登录 Chat App 消息服务控制台。在左侧...