最大消息大小 云消息队列 Kafka 版 能收发的消息的最大值。消息的最大值上限为10 MB，不区分标准版实例和专业版实例。修改该配置前，请确认修改值是否匹配生产和消费客户端相应配置。消费位点保留时长 消费位点的最大保留时长，从提交消费...
本文为您介绍 云消息队列 Kafka 版 计费的常见问题。为什么购买了按小时后付费实例或Serverless实例后不使用也要收费？按照Topic规格购买的实例，如何转换为按照分区规格购买类型？为什么按流量峰值收费？按流量峰值收费的依据是什么？为...
云存储和Local存储。云消息队列 Kafka 版 实例支持云存储和Local存储。详情请参见 存储引擎对比。
订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 为什么消费客户端频繁出现Rebalance？消费端从服务端拉取不到消息或拉取消息缓慢 为什么不推荐使用Sarama Go客户端收发消息？使用云消息队列 Kafka 版时出现消息...
如需使用SDK接入 云消息队列 Kafka 版 收发消息，您需要根据实例的网络环境类型来配置接入点。本文介绍如何在 云消息队列 Kafka 版 控制台查看接入点。背景信息 云消息队列 Kafka 版 提供以下类型的接入点：默认接入点：适用于在VPC环境...
使用云消息队列 Kafka 版时客户端的报错及解决方案 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息
详细信息 客户端首次接入云消息队列 Kafka 版时如果出现异常，您可以通过以下三个方面进行排查：网络连通问题：通常有如下几种情况可能会导致网络不通，客户端无法连接云消息队列 Kafka 版的服务端。ECS实例（客户端）与云消息队列 Kafka ...
本文为您介绍 云消息队列 Kafka 版 客户端消费消息的常见问题。客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 为什么消费客户端频繁出现Rebalance？消费端从服务端拉取不到消息或拉取消息缓慢 为什么不推荐使用Sarama Go客户端...
在控制台上可以查看和设置监控告警功能，但是在2018年11月以前部署的 云消息队列 Kafka 版 集群不支持上报监控告警数据，因此需要升级旧版本的 云消息队列 Kafka 版 实例集群，让它可以上报监控告警数据。若您要升级您的 云消息队列 Kafka ...
针对各种业务需求，云消息队列 Kafka 版 提供相关的实践教程，您可以根据本文查看适合您业务的实践教程文档。实践教程 最佳实践 生态对接
问题现象 在 云消息队列 Kafka 版 控制台 的 Group 管理 页面查看您Kafka集群上所有存在的Group时，显示的Group数量多于您手动创建的数量。可能原因 若Group的 自动创建 栏为 否，说明此Group创建于 云消息队列 Kafka 版 控制台 的 Group ...
正式商用细则 云消息队列 Kafka 版 的正式商用细则如下：为提高服务质量和用户体验，云消息队列 Kafka 版 全部以商用实例方式提供服务。实例的基本规格和定价信息请参见 计费概述。如果您有共享服务需求，可考虑阿里云 云消息队列 RocketMQ...
升级Broker可能产生以下影响：升级过程中，会逐个重启 云消息队列 Kafka 版 集群中所有的Broker。在重启Broker的过程中服务不会中断，但是从每个Broker重启完成之后的5分钟内消费的分区消息可能会发生乱序（Serverless版本实例和Confluent...
如果您对 云消息队列 Kafka 版 服务的消费情况产生疑问，可以查看消费明细。查看费用账单 在费用与成本的 账单 目录下的账单维度，查看您的消费信息。账单概览：显示消费趋势分析报表、产品消费分析图、按账期（即月份）查看自身的消费汇总...
在 交换机 页面，查看以下信息：交换机 实例ID/名称 专有网络 可用区 说明 请根据该页面的可用区（A～G）在 云消息队列 Kafka 版 控制台中选择对应的可用区（A～G）。例如，某VPC交换机（vSwitch）显示在 可用区B，那么在 云消息队列 Kafka...
开通 云消息队列 Kafka 版 服务需要使用阿里云其他云产品中的资源，因此，您需要先授权 云消息队列 Kafka 版 访问您所拥有的其他阿里云资源。前提条件 注册阿里云账号并完成实名认证。详情请参见 注册阿里云账号。背景信息 为了方便您快速...
云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。前置概念 阅读本文前，您可能需要了解如下概念：什么是消息队列？什么是PaaS？三分钟了解云消息队列 ...
当您使用资源组对资源进行...不支持资源组级别授权的操作 消息队列Kafka版中不支持资源组级别授权的操作（Action）如下：操作（Action）操作描述 alikafka:AddQuota-alikafka:CheckCreateSlr-alikafka:ConsoleClearPretendStatus-alikafka:...
本文为您介绍 云消息队列 Kafka 版 实例小版本升级过程中遇到的问题及相关说明。实例小版本升级是否可以推迟？云消息队列 Kafka 版 实例版本升级时会创建一条调度任务，如需推迟升级，可通过修改该调度任务的执行时间来实现：登录 云消息...
步骤一：准备云消息队列 Kafka 版数据 向Topic testkafka中写入数据，以作为迁移至MaxCompute中的数据。由于 云消息队列 Kafka 版 用于处理流式数据，您可以持续不断地向其中写入数据。为保证测试结果，建议您写入10条以上的数据。登录 云...
本产品（云消息队列 Kafka 版/2019-09-16）的OpenAPI采用 V3版本请求体&签名机制 签名风格，签名细节参见 V3版本请求体&签名机制。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术...
云消息队列 Kafka 版 优化了集群增加大量分区后带来的性能下降问题。自建开源Apache Kafka集群分区数大于1000后，集群性能开始急剧下降，遭遇性能瓶颈。阿里云 云消息队列 Kafka 版 对此进行了优化，单个集群的分区数理论上没有上限。但...
在使用自建Kafka集群时，当您希望业务的成本更低、弹性更强、可靠性更高时，您可以将自建Kafka集群迁移上至 云消息队列 Kafka 版，云消息队列 Kafka 版 提供全托管、免运维的服务可以让您只需专注于业务开发，无需部署运维。注意事项 迁移...
云消息队列 Kafka 版 云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。更...
问题现象 我在 云消息队列 Kafka 版 控制台 上，未查看到对应的Group，但此Group下却有消费线程在消费消息。可能原因 如果客户端使用 assign 方式消费消息，那么即使不创建Group，也可能消费消息。如果客户端使用 subscribe 方式消费消息，...
当您想要将A地域的 云消息队列 Kafka 版 上的业务无损迁移至B地域，或者创建实例后想复制已有实例元数据（Topic、Group）配置时，您可以使用 云消息队列 Kafka 版 提供的迁移工具将某个 云消息队列 Kafka 版 实例的Topic、Group迁移至另...
云消息队列 Kafka 版（ApsaraMQ for Kafka）秉持开放的原则拥抱开源，全面融合Kafka开源生态，做到无缝迁移，打造更安全、更可靠、更易运维的Kafka企业级消息服务。
背景信息 升级大版本 升级大版本是指跨版本升级，例如将 云消息队列 Kafka 版 实例的版本从0.10.x版本升级至2.x版本。重要 目前新部署实例仅支持2.x版本，存量0.10.x可正常使用。由于2.x版本的消息存储格式与0.10.x版本不同，您在完成升级...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
步骤四：调用 云消息队列 Kafka 版 OpenAPI 示例一：获取支持阿里云CLI调用 云消息队列 Kafka 版 OpenAPI列表 以下示例将为您展示如何使用-help 选项获取支持阿里云CLI调用的 云消息队列 Kafka 版 OpenAPI列表。您也可在 API概览 中查看...
本文介绍 云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK（Software Development Kit）即软件开发工具包，包含示例Demo、库文件、编译工具链以及编译脚本等，不需要开发者进行任何其他的配置，直接可以在SDK对应目录环境下，进行...
云消息队列 Kafka 版 数据导出至Elasticsearch的格式示例如下：{"took":8,"timed_out":false,"_shards":{"total":5,"successful":5,"skipped":0,"failed":0 },"hits":{"total":{"value":1,"relation":"eq"},"max_score":1.0,"hits":[{"_...
CSV 消息队列Kafka、Upsert Kafka、云消息队列 RocketMQ 版、StarRocks、对象存储OSS。Avro 消息队列Kafka、Upsert Kafka、对象存储OSS。Confluent Avro 消息队列Kafka、Upsert Kafka。Raw 消息队列Kafka、Upsert Kafka、对象存储OSS。...
队列（MessageQueue）：云消息队列 RocketMQ 版 消息传输和存储的实际单元容器，类比于Kafka中的分区。云消息队列 RocketMQ 版 通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。消息（Message）：云消息队列 ...
背景信息 企业A购买了 云消息队列 Kafka 版，企业A希望用户A只能从 云消息队列 Kafka 版 的所有Topic中消费消息，而不能向 云消息队列 Kafka 版 的任何Topic生产消息。注意事项 Kafka为公网/VPC类型实例提供默认SASL用户，默认SASL用户仅...
您可以设置访问 云消息队列 Kafka 版 的白名单，配置在白名单中的IP地址与端口才允许访问 云消息队列 Kafka 版 实例。前提条件 您已购买 云消息队列 Kafka 版 实例，且该实例处于 服务中 的状态。实现原理 白名单功能基于用户安全组实现：...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
本文介绍 云消息队列 Confluent 版 的产品...2024-08-20 功能名称 功能描述 功能类型 相关文档 日志管理 支持将 云消息队列 Confluent 版 实例的消息操作日志推送到日志服务。开通该服务后，您可以查询客户端的所有请求日志。新增 日志管理
当事件产生时，IMS服务端会将回调内容写入 轻量消息队列（原 MNS）的队列中，通过消费队列中的消息获取事件。操作指南 您可以通过 智能媒体服务控制台 或OpenAPI两种方式设置事件回调，操作步骤，请参见 设置回调事件。
顺序存储：云消息队列 RabbitMQ 版 采用存算分离的分布式架构，同一Queue 的消息分布在多个节点的多个分区中。但计算节点会从存储节点读取这些分区的消息，进行归并排序后再返回给消费者，从而实现与开源版本一样的顺序消费语义。存算分离...