迁移Group上云
本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将自建Kafka集群的 Group 迁移到 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作：下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云消息队列 Kafka 版 ...
如何快速使用云消息队列 Kafka 版的Java SDK收发消息
六分钟上手 云消息队列 Kafka 版。文档教程 快速入门
是否支持延迟消息？
和开源Apache Kafka一样，云消息队列 Kafka 版 同样不支持延迟消息。
计费概述
说明 云消息队列 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 版 的常见问题与以及服务等级协议。服务支持 常见问题 相关协议
自定义事件源消息队列Kafka版
最新位点 网络配置 事件总线EventBridge 集成 消息队列Kafka版 数据时支持的网络连接方式。默认网络 自建公网 默认网络 专有网络VPC 选择VPC ID。当 网络配置 选择为 自建公网 时需要配置此参数。vpc-bp17fapfdj0dwzjkd*交换机 选择vSwitch...
配置白名单
您可以设置访问 云消息队列 Kafka 版 的白名单，配置在白名单中的IP地址与端口才允许访问 云消息队列 Kafka 版 实例。前提条件 您已购买 云消息队列 Kafka 版 实例，且该实例处于 服务中 的状态。注意事项 公网/VPC类型的实例默认白名单为0...
Topic的存储有哪些类型？
云存储和Local存储。云消息队列 Kafka 版 实例支持云存储和Local存储。详情请参见 存储引擎对比。
如何获取部署实例时需要的VPC信息？
在 交换机 页面，查看以下信息：交换机 实例ID/名称 专有网络 可用区 说明 请根据该页面的可用区（A～G）在 云消息队列 Kafka 版 控制台中选择对应的可用区（A～G）。例如，某VPC交换机（vSwitch）显示在 可用区B，那么在 云消息队列 Kafka...
开发参考
本文介绍 云消息队列 Kafka 版 的SDK和API及Terraform的支持情况，供您进行对应的开发操作。开发参考 API参考指南 SDK参考 Terraform
实践教程
针对各种业务需求，云消息队列 Kafka 版 提供相关的实践教程，您可以根据本文查看适合您业务的实践教程文档。实践教程 最佳实践 生态对接
为什么Group的状态一直处于“删除中”？
问题现象 在 云消息队列 Kafka 版 控制台 的 Group 管理 页面删除Group后，此Group的状态一直处于 删除中。可能原因 Group中存在活跃的订阅关系。Group上有消费线程在提交新的消费位点。解决方案 登录 云消息队列 Kafka 版 控制台，查看...
设置实例到期欠费预警提醒通知
欠费预警接收设置 登录 云消息队列 Kafka 版 控制台。单击页面右上方的 图标，进入 消息中心 页面。在左侧导航栏，单击 基本接收管理。在 基本接收管理 页面的 消息类型 中勾选 产品的欠费、停服、即将释放相关信息通知，单击 修改。在 ...
Filebeat发送失败问题
问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面，您已成功创建Topic，但使用Filebeat向该Topic发送消息却出现 Request was for a topic or partition that does not exist on this broker.的错误提示。可能原因 Filebeat向...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
如何进行发送消息的测试？
您可以直接在 云消息队列 Kafka 版 控制台进行发送消息的测试。您可以在控制台的 Topic管理 页面，单击目标Topic右侧的 发送消息，进行消息发送测试，以验证集群是否运转正常。
迁移数据上云
云消息队列 Kafka 版 集群的SSL接入点（可在 云消息队列 Kafka 版 控制台获取）bootstrap.servers=XXX.XXX.XXX.XXX:9093#数据压缩方式 compression.type=none#truststore（使用步骤1下载的文件）ssl.truststore.location=kafka.client....
为什么在控制台看不到Group的订阅关系？
问题现象 您已启动某个Group的消费线程，但在 云消息队列 Kafka 版 控制台 的 Topic 详情 页面的 订阅关系 页签，查不到Topic被Group订阅的信息，或者在 Group 详情 页面的 消费状态 页签，查不到该Group订阅的Topic信息。可能原因 客户端...
查看Rebalance详情
背景信息 Rebalance是 云消息队列 Kafka 版 对分区和Consumer Group之间的消费对应关系进行重分配的过程。消费客户端出现Rebalance可能是以下原因：当消费者主动新增订阅或者取消订阅时，会触发该Consumer Group内的Rebalance。当Topic的...
云监控
查看云监控数据 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，选择 可观测>云监控。在 云监控 页面，单击 报警规则 页签，单击要查看监控数据的资源页签...
使用Spring Cloud框架收发消息
本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 并收发消息。前提条件 安装1.8或以上版本JDK。安装2.5或以上版本Maven。下载 kafka-spring-stream-demo，并将其上传在准备好的Linux操作系统。确保您的 云消息队列 Kafka 版 ...
步骤三：创建资源
当使用 云消息队列 Kafka 版 进行消息收发时，您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
为什么限制Topic总数（分区总数）？
Topic总数（分区总数）太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版 的存储和协调机制是以分区为粒度的，分区数太多，会导致存储碎片化严重，集群性能和稳定性都会急剧下降。
访问链接与端口
开启公网 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，在 实例列表 页面单击目标实例名称。在左侧导航栏，单击 访问链接与端口。在目标服务右侧，打开 开启 开关，为服务开启公网。说明 开启...
创建SLS Sink Connector
本文介绍如何创建使用SLS Sink Connector，您可通过SLS Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至日志服务SLS。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 创建日志项目（Project）。详细...
RAM跨云账号授权
背景信息 企业A开通了 云消息队列 Kafka 版，该企业需要企业B代为操作 云消息队列 Kafka 版 的资源，例如实例、Topic、Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为 云消息队列 Kafka 版 所有者。企业A希望可以授权企业B来...
创建数据投递任务
当您需要将某Prometheus实例的监控数据导出，进行自定义业务处理时，可以使用Prometheus数据投递功能，将Prometheus实例数据投递至云消息队列Kafka版或云原生大数据计算服务（MaxCompute）处理。您可以根据业务需求，选择相应的投递目标。...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
创建数据投递任务
当您需要将某Prometheus实例的监控数据导出，进行自定义业务处理时，可以使用Prometheus数据投递功能，将Prometheus实例数据投递至云消息队列Kafka版或云原生大数据计算服务（MaxCompute）处理。您可以根据业务需求，选择相应的投递目标。...
实例支持哪些开源版本？
云消息队列 Kafka 版 标准版与专业版实例支持的开源版本是2.2.0、2.6.2版本，同时兼容对应的2.2.x、2.6.x的客户端。您在购买实例后，可在部署实例时选择2.2.0或2.6.2版本。建议您使用2.2.0及以上的版本。如需升级版本，请参见 升级实例版本...
创建前提
AliyunKafkaFullAccess：管理 云消息队列 Kafka 版 的权限。AliyunFCFullAccess：管理 函数计算FC（Function Compute）的权限。AliyunEventBridgeFullAccess：管理 事件总线EventBridge 的权限。目标服务的管理权限。除上述必要权限外，如...
为什么购买了按量付费实例后不使用也要收费？
按量付费模式与购买后是否实际使用无关。您在购买 云消息队列 Kafka 版 按量付费实例后，系统会为您分配相应的实例资源。因此，按量付费模式是以实例单价×服务时间计费的，与您购买后是否使用该实例无关。
ACL授权
ACL授权 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在 实例列表 页面，单击目标实例名称。在左侧导航栏，选择 用户管理，单击目标用户右侧 操作 列的 授权。配置项 说明 资源类型 实例：对集群授权。Topic：对某一个...
SSL证书算法升级说明
前提条件 您已购买 云消息队列 Kafka 版 公网实例，且实例处于 服务中 状态。背景信息 您的实例开启公网时，会启动SSL相关的端口，在 云消息队列 Kafka 版 控制台 的 配置信息 页面可以看到SSL证书算法位数。请根据您的安全需求按需选择...
Ruby SDK收发消息
本文介绍如何使用Ruby SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 您已安装Ruby。更多信息，请参见 安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备配置 可选：下载SSL根...
C# SDK收发消息
本文介绍如何使用C#SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境配置 您已安装.NET。更多信息，请参见 安装.NET 。安装C#依赖库 执行以下命令安装C#依赖库。dotnet add package-v 1.5.2 Confluent.Kafka 准备配置 可选：下载...
- 产品推荐
- 这些文档可能帮助您