中间件 支持免费试用

云消息队列 Kafka 版

高吞吐数据管道,日志与流处理的标准入口

云消息队列 Kafka 版是全托管的 Apache Kafka 服务,兼容开源 Kafka 协议与生态工具。Kafka 以高吞吐、可持久化、可水平扩展著称,是大数据领域日志采集、流处理与数据管道的事实标准。托管版免去了 ZooKeeper 与 Broker 集群的运维负担。

产品概述

云消息队列 Kafka 版是全托管的 Apache Kafka 服务,兼容开源 Kafka 协议与生态工具。Kafka 以高吞吐、可持久化、可水平扩展著称,是大数据领域日志采集、流处理与数据管道的事实标准。托管版免去了 ZooKeeper 与 Broker 集群的运维负担。

全兼容开源:兼容 Apache Kafka 协议,现有客户端与工具直接可用
高吞吐:单实例可达百万级 TPS,适合大规模日志与数据管道
免运维:无需部署与管理 Broker、ZooKeeper 集群
弹性扩容:支持在线扩容磁盘与计算规格,业务增长无需重建集群
生态集成:与 Flink、MaxCompute、SLS、Hologres 无缝对接
最适合谁

有日志采集与实时数据管道需求的大数据团队;需要高吞吐事件流处理的业务;已使用 Kafka 生态希望降低运维成本的团队。

规格速查

以下参数用于快速比对本产品的核心能力边界。

协议兼容 Apache Kafka 协议,支持主流客户端版本
版本 支持 Kafka 2.x / 3.x
吞吐 单实例百万级 TPS(视规格)
存储 ESSD 云盘,按需扩容
分区 支持数千分区
数据保留 支持按时间或容量保留策略
安全 VPC 隔离、SASL 认证、SSL 加密
监控 提供消费延迟、堆积量、TPS 等指标

价格与计费

价格为整理时的参考区间,实际以下单页面为准。计费模式:包年包月(按实例规格) · 按量付费 · Serverless 按用量计费。

套餐 / 规格 配置说明 参考价格 备注
标准版 按实例规格 按量 元/小时 中小业务
专业版 高规格与高可用 按量 元/小时 生产环境
存储费用 按使用量 按量
Serverless 版 按吞吐与存储 按量 弹性业务
包年包月(按实例规格)按量付费Serverless 按用量计费

省钱提示:长期稳定负载优先包年包月并叠加节省计划;无状态批处理可用抢占式实例,成本可低至按量价的 10%。 查看成本优化指南 →

适用场景

日志采集与集中传输 实时数据管道 流计算数据源(Flink) 用户行为埋点收集 IoT 设备数据接入 数据库变更日志分发

功能拆解

开源全兼容

完全兼容 Apache Kafka 协议,现有的生产者/消费者代码、Kafka Connect、Kafka Streams 以及各类监控工具都可直接使用,迁移无需改造。

高吞吐设计

基于顺序写磁盘与零拷贝技术,单实例可支撑百万级 TPS,是处理海量日志与事件数据最高效的消息系统。

免运维集群

Broker 集群、ZooKeeper、磁盘扩容、分区重平衡与故障恢复全部由平台负责,业务只需关注 Topic 与消费逻辑。

与流计算集成

作为 Flink 的标准数据源与结果表,可构建「Kafka → Flink → Hologres/MaxCompute」的实时数据管道,实现数据的实时采集、处理与入库。

数据可重放

消息按保留策略持久化存储,消费者可重置位点重新消费历史数据。这在数据处理逻辑出错需要重新计算时非常有用。

安全与隔离

支持 VPC 内网访问、SASL 认证与 SSL 加密传输,也支持基于 ACL 的 Topic 级权限控制,满足多团队共享集群的安全要求。

常见问题

Kafka 和 RocketMQ 怎么选?

日志采集、数据管道、流计算数据源选 Kafka;业务系统间的消息通信、事务消息、延时消息选 RocketMQ。核心区别在 Kafka 偏向「数据流」,RocketMQ 偏向「业务消息」。

分区数怎么设置?

分区数决定最大并行消费度。建议按预期消费吞吐量除以单消费者处理能力估算,并预留一定余量。但分区过多会增加元数据开销与重平衡时间,通常单 Topic 控制在数十个分区内较合理。

消费延迟高怎么办?

先查看是否有消费组堆积。常见原因是消费者实例数少于分区数(无法充分利用并行度),或单条消息处理耗时过长。可增加消费者实例、提高批量处理效率或优化下游写入性能。

相关产品

准备使用 Kafka?

新用户可先领取免费试用额度验证,再决定购买配置与时长。

  • 全兼容开源
  • 高吞吐
  • 免运维