计费概述
说明 云消息队列 Kafka 版 的Connector组件依赖于 事件总线，云消息队列 Kafka 版 不会额外收取费用。事件总线 的计费说明，请参见 计费说明。同时，阿里云不承诺Connector的SLA，使用Connector所依赖的其他产品的SLA和费用说明请以对应...
无法ping通云消息队列 Kafka 版的接入点
问题描述 无法ping通云消息队列 Kafka 版的接入点。本地客户端无法telnet Kafka或提示连接超时（Connection timed out）。问题原因 为了保证安全，云消息队列 Kafka 版集群默认禁ping。连接VPC接入点时，客户端与Kafka不在同一VPC下。解决...
如何通过代理访问云消息队列 Kafka 版实例
概述 暂不支持通过代理访问云消息队列 Kafka 版实例，具体请查看 详细信息。详细信息 云消息队列 Kafka 版的客户端访问服务端的原理如下。通过 bootstrap.servers 随机访问服务器获取Metadata。通过Metadata里的IP地址进行后续的消息收发。...
接入点对比
云消息队列 Kafka 版 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接入点适用于无需对传输链路加密但需对消息收发鉴权；需要链路加密和消息鉴权，建议使用SSL...
基本概念
Connector 云消息队列 Kafka 版 的组件，用于 云消息队列 Kafka 版 和其他阿里云服务之间的数据同步。更多信息，请参见 Connector概述。标签 用于识别 云消息队列 Kafka 版 资源。您可以将作用相同的 云消息队列 Kafka 版 的资源归类，便于...
服务支持
本文汇总了 云消息队列 Kafka 版 的常见问题与以及服务等级协议。服务支持 常见问题 相关协议
基于Flink的资讯场景实时数仓
部署架构图 选用的产品 云消息队列 Kafka 版 云消息队列 Kafka 版 是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等，是大数据生态中不可或缺的...
Topic的存储有哪些类型？
云存储和Local存储。云消息队列 Kafka 版 实例支持云存储和Local存储。详情请参见 存储引擎对比。
开发参考
本文介绍 云消息队列 Kafka 版 的SDK和API及Terraform的支持情况，供您进行对应的开发操作。开发参考 API参考指南 SDK参考 Terraform
创建RabbitMQ Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和...
实践教程
针对各种业务需求，云消息队列 Kafka 版 提供相关的实践教程，您可以根据本文查看适合您业务的实践教程文档。实践教程 最佳实践 生态对接
创建MQTT Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买...
使用Kafka Connect将SQL Server数据同步至云消息队列 ...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
报警项状态显示数据不足怎么办？
可能原因 老版 云消息队列 Kafka 版 实例不支持报警数据上报。解决方案 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击 配置信息 页签，然后单击...
降低实例配置
如果您的 云消息队列 Kafka 版 实例的公网流量消耗远小于购买的公网流量配置，或者分区的使用量远小于购买的分区数量，您可以降低公网流量和分区数量配置，从而节约成本。本文介绍如何在 云消息队列 Kafka 版 控制台降低实例的公网流量、...
接入Logstash
本文介绍如何将 云消息队列 Kafka 版 接入Logstash。Logstash Logstash是开源的服务器端数据处理管道，能够同时从多个数据源采集数据，然后对数据进行转换，并将数据写入指定的存储中。Logstash的数据处理流程如下：输入：采集各种格式、...
为什么在控制台看不到Group的订阅关系？
问题现象 您已启动某个Group的消费线程，但在 云消息队列 Kafka 版 控制台 的 Topic 详情 页面的 订阅关系 页签，查不到Topic被Group订阅的信息，或者在 Group 详情 页面的 消费状态 页签，查不到该Group订阅的Topic信息。可能原因 客户端...
创建RabbitMQ Sink Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 云消息队列 RabbitMQ 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于服务中状态。具体步骤，请参见 步骤二：购买和...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
创建RocketMQ Sink Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
使用云消息队列 Kafka 版时客户端的报错及解决方案
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
仪表盘
云消息队列 Kafka 版 的所有指标数据已保存到您的阿里云可观测监控 Prometheus 版中，您可以通过 可观测监控 Prometheus 版 提供的API将 云消息队列 Kafka 版 的仪表盘的指标数据接入到本地自建Grafana中。具体操作，请参见 将Prometheus的...
创建RocketMQ Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务，将 云消息队列 RocketMQ 版 的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买Kafka实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已...
购买和部署实例
获取云消息队列 Kafka 版访问授权。步骤一：购买实例 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，然后单击 购买实例。在 请选择您要创建的实例的付费方式 面板，选择 实例系列 为 Confluent ...
创建MNS Sink Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 消息服务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您...
为什么限制Topic总数（分区总数）？
Topic总数（分区总数）太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版 的存储和协调机制是以分区为粒度的，分区数太多，会导致存储碎片化严重，集群性能和稳定性都会急剧下降。
创建MNS Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务，将 消息服务MNS 中的数据快速导入 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。...
搭配云HBase和Spark构建一体化数据处理平台
实时计算：通过X-Pack Spark Streaming实时地消费 云消息队列 Kafka 版 的消息，写入到云HBase中对外提供在线查询。实时存储与检索：云HBase融合Solr以及Phoenix SQL层能够提供海量的实时存储，以及在线查询检索。批处理、数仓及算法：在线...
访问链接与端口
开启公网 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，在 实例列表 页面单击目标实例名称。在左侧导航栏，单击 访问链接与端口。在目标服务右侧，打开 开启 开关，为服务开启公网。说明 开启...
升级多可用区
前提条件 您使用的 云消息队列 Kafka 版 实例类型为 专业版。实例当前为单可用区部署。实例当前读写流量水位没有接近购买规格峰值。实例大版本必须为2.2.0或以上版本，小版本建议您使用最新版本。升级影响 该操作服务不会中断，但可能导致...
生态对接概述
本文介绍 云消息队列 Kafka 版 支持对接的生态。阿里云生态 云数据库HBase版 基于HBase和Spark的数据处理平台 阿里云实时计算Flink 基于Flink的资讯场景实时数仓 大数据计算服务MaxCompute 接入MaxCompute 数据传输服务DTS 使用DTS同步...
开启ACL
云消息队列 Kafka 版 V2系列专业版 和V3系列Serverless 实例提供ACL功能，您可以在开启此功能后按需为SASL用户授权，通过SASL接入点接入实例。前提条件 实例规格类型为V2系列专业版 或V3系列Serverless版。实例运行状态为 服务中。实例大...
为什么购买了按量付费实例后不使用也要收费？
按量付费模式与购买后是否实际使用无关。您在购买 云消息队列 Kafka 版 按量付费实例后，系统会为您分配相应的实例资源。因此，按量付费模式是以实例单价×服务时间计费的，与您购买后是否使用该实例无关。
云监控
message_accumulation_onetopic userId、instanceId、consumerGroup、topic count 查看云监控数据 查看监控数据的步骤如下：登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例...
实例支持哪些开源版本？
云消息队列 Kafka 版 标准版与专业版实例支持的开源版本是2.2.0、2.6.2版本，同时兼容对应的2.2.x、2.6.x的客户端。您在购买实例后，可在部署实例时选择2.2.0或2.6.2版本。建议您使用2.2.0及以上的版本。如需升级版本，请参见 升级实例版本...
为什么消息已经过期还未被删除？
问题现象 您发送的消息在服务端...磁盘容量充足，使用率低于75%，云消息队列 Kafka 版 设置的集中清理消息的时间还未到，消息不会被删除。说明 磁盘使用率低于75%时，在每天凌晨4点，云消息队列 Kafka 版 集中删除超过 消息保留时长 的消息。
SSL证书算法升级说明
前提条件 您已购买 云消息队列 Kafka 版 公网实例，且实例处于 服务中 状态。背景信息 您的实例开启公网时，会启动SSL相关的端口，在 云消息队列 Kafka 版 控制台 的 配置信息 页面可以看到SSL证书算法位数。请根据您的安全需求按需选择...
管理预警联系人
添加预警联系人 登录 云消息队列 Kafka 版 控制台。在左侧导航栏，选择 常用工具/链接>预警联系人。在 预警联系人 页面，单击 添加联系人。在 添加联系人 面板，填写以下信息，然后单击 确定。参数 描述 姓名 联系人姓名。手机号码 联系人...
按量计费转包年包月
前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例运行状态处于 服务中 或 未部署。具体操作，请参见 步骤二：购买和部署实例。注意事项 按量计费转包年包月的过程中，实例始终处于服务中状态，不会因为实例重启而导致服务短暂不...
- 产品推荐
- 这些文档可能帮助您