发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
状态不一致
非预期的客户端连接 现象：部分消息发送后客户端未收到。按 Message ID 查询消息（具体操作方法详见 消息查询）后，发现部分消息已发送至 Broker，但未投递给下游消费者。查看目标 Group ID 的消费者状态（具体操作方法详见 查看消费者状态...
什么是Topic
在发布/订阅消息的MQTT协议中，Topic用于定义消息传输的通道和路径，设备通过Topic将消息发布到物联网平台，物联网平台将消息发送给订阅Topic的设备。为方便海量设备基于Topic进行通信，简化授权操作，物联网平台定义了产品Topic类和设备...
基础概念
集成流引擎自身定义了一些核心数据类型，主要包括：类名 简介 相关文档 StepMessage 集成流节点之间传递的消息格式。StepMessage Entity 承载数据的实体，是对二进制数据的封装。Entity HTTP类 对HTTP Request、Response的封装，使用HTTP...
无影魔方AS05
新增 悬浮球新增消息中心功能，您可接收到 管控消息、系统消息 和 协同消息 三类消息。优化 优化打印机界面使用交互。新增 新增支持触摸屏功能。错误修复 修复了部分已知问题。V6.1.3-2023年5月 变更类型 变更说明 新增 新增局域网内点对点...
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 ...
无影23.8寸一体机US01
新增 悬浮球新增消息中心功能，您可接收到 管控消息、系统消息 和 协同消息 三类消息。优化 优化打印机界面使用交互。错误修复 修复了部分已知问题。V6.1.3-2023年5月 变更类型 变更说明 新增 新增局域网内点对点的控制台远程硬件终端云...
现代IM系统中的消息系统—模型
本章节主要介绍表格存储（Tablestore）的Timeline模型基本功能以及核心组件，并且会通过IM消息系统场景，介绍如何基于Timeline实现IM场景下消息同步、存储和索引等基本功能。Timeline模型 Timeline模型以简单为设计目标，核心模块主要包括...
消息 Mesh
消息验证：消息验证在基于事件驱动的微服务架构中正变得越来越重要，通过将这部分能力下沉到 Sidecar，不仅可以让业务系统无缝集成消息验证能力，也可以让 Sidecar 通过 Schema 理解消息内容，并进一步具备恶意内容识别等安全管控能力。...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。更多信息，请参见 VPC...
盒式云电脑终端AS01
新增 悬浮球新增消息中心功能，您可接收到 管控消息、系统消息 和 协同消息 三类消息。优化 优化打印机界面使用交互。新增 新增支持触摸屏功能。错误修复 修复了部分已知问题。V6.1.3-2023年5月 变更类型 变更说明 新增 新增局域网内点对点...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
集群消费和广播消费
每个消费者只处理其中一部分消息，从而提高消息的处理效率和吞吐量。分布式数据处理：在大规模数据处理的场景中，使用集群消费模式可以将数据分发给多个处理节点进行并行处理。每个节点只处理其中一部分数据，从而加速数据处理的速度。注意...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
弹性搜索的审计事件
PostEmonTryAlarmRule 发送报警消息。RebootInstanceNode 重启阿里云Elasticsearch实例中的ECS节点。RecommendTemplates 查询推荐的Elasticsearch集群配置。ReinstallCollector 重试安装在创建时没有安装成功的Beats采集器。RemoveApm 删除...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
消息过滤
若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的消息。应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
接口说明
140018 TTS_CLOSED 没有编译TTS部分代码。表示当前SDK中不包含TTS功能，请更换正确SDK运行。参数配置相关 状态码 状态消息 原因 解决方案 140100 TTS_PARAM_INVALID 参数无效。初始化或设置参数时有无效入参，比如空workspace、空回调、空...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
为什么不推荐使用Sarama Go客户端收发消息？
问题现象 所有Sarama Go版本客户端存在以下已知问题：当Topic新增分区时，Sarama Go客户端无法感知并消费新增分区，需要客户端重启后，才能消费到新增分区。当Sarama Go客户端同时订阅两个以上的Topic时，有可能会导致部分分区无法正常消费...
蓝牙Mesh模组软件规范
本文在蓝牙技术联盟发布的Mesh Profile的基础上，做了一些协议上的定制，细化了部分协议规则，作为蓝牙Mesh模组软件规范，指导芯片或者模组厂家软件设计，开发 智能单品并对接生活物联网平台，包括自有品牌项目与天猫精灵生态项目均遵循本...
Windows客户端和macOS客户端
无 新增 新增消息中心 云电脑内新增 消息中心，您可接收到 管控消息、系统消息 和 协同消息 三类消息；其中包含可交互式消息，如您可预约镜像更新时间，可跳过执行当天的管理员定时任务。此外还可查询和管理历史消息。查看消息 新增 悬浮球...
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
身份验证模板最佳实践
说明 如果您在发送消息之前不执行“握手”，或消息未通过资格检查，则发送的消息将显示复制验证码按钮(Copy code)，而不是一键自动填写按钮(Autofill)。资格检查 在收到身份验证模板消息之后，WhatsApp应用会执行以下检查。如果任意检查...
如何快速测试云消息队列 Kafka 版服务端是否正常？
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
用户管理
作为集群安全的一部分，云消息队列 Confluent 版 提供了用户管理功能。您可以在用户管理页面完成新增用户、删除用户等操作。本文介绍用户管理的具体操作步骤。查看用户列表 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表...
消息发送重试和流控机制
背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试会带来什么不足？消息流控 云消息队列 RocketMQ 版 的流控机制主要为您解答...
将云消息队列 Kafka 版接入阿里云Elasticsearch
随着时间的积累，云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...
错误码字典
2074 query msg-center hsf error 调用消息中心错误。服务端发生未知异常，需要联系服务人员。2075 share model not config for this product 分享模式未配置。产品没有设置分享模式，前往产品开发中心配置分享模式。2077 can't get ...
能力介绍
数据集成介绍 数据集成标准化的目标是规范应用之间数据的传递方式和表达方式。传递方式：即应用之间的数据如何流通。平台提供了对数据进行增删改查的4个API，以及HTTP2方式的消息订阅机制。表达方式：即应用之间如何对数据内容有一致的理解...
ECS系统事件概述
应用场景 通知风险和异常 针对未在ECS控制台展示的系统事件（包括影响ECS资源可用性和造成性能受损的系统事件），例如因系统维护重启实例等运维事件、实例到期等费用预警事件，阿里云会将系统事件推送至ECS控制台展示，部分高危事件还会...
全局服务
Query：使用Query方式时，参数会作为URL的查询字符串的一部分附加在请求URL中，按照键值对的形式传递给服务。例如：http://example.com/api?param1=value1¶m2=value2 Header：使用Header方式时，参数会作为HTTP请求的头部信息进行传递...
EMR Kafka磁盘故障运维
业务场景 Kafka将日志数据存储到磁盘中，当磁盘出现故障时，会导致磁盘IO能力下降、集群吞吐下降、消息读写延时或日志目录offline等问题。这些情况有可能影响到线上业务平稳运行、数据丢失、Kafka集群容错能力下降，单块盘故障甚至有可能...
错误码
可能原因为Enclave管理进程所需内存不足、系统已有线程数已达上限或Enclave CLI主进程被禁止创建守护进程，可尝试释放部分系统资源后重新运行命令或重启实例后重新运行命令。E07 目录读取失败 在运行 describe-enclave 子命令时Enclave CLI...
Web客户端
新增 新增消息中心功能 新增消息中心，支持管理用户消息，支持管理员通知消息、云电脑分发回收消息等，同时支持批量已读和删除。新增 新增支持手机验证码登录功能 管理员开通组织ID及手机验证码登录功能后，支持终端用户使用手机号和验证码...
消息推送常见问题
本文汇总了接入及使用消息推送组件的过程中经常出现的一些问题及其解决方法。通用问题 关于权限的说明 Android 6.0 后，需要用户手动授予手机权限，如读写 SD 卡。为了更加精准的发送推送，建议开发者引导获取消息推送所需权限。日志无法...
自定义配置
kafka发送消息自动透传上下文：发送时自动往Kafka消息中添加若干个Header用以将发送链路以及消费链路关联，注意仅到kafka版本为v0.11.0及以上可打开，否则会导致发送消息异常。线程池、连接池监控：支持Tomcat/Dubbo/HSF等框架的线程池、...
- 产品推荐
- 这些文档可能帮助您