开源全兼容
完全兼容 Apache Kafka 协议,现有的生产者/消费者代码、Kafka Connect、Kafka Streams 以及各类监控工具都可直接使用,迁移无需改造。
输入关键词开始搜索,支持产品名、别名、场景与关键词。
云消息队列 Kafka 版是全托管的 Apache Kafka 服务,兼容开源 Kafka 协议与生态工具。Kafka 以高吞吐、可持久化、可水平扩展著称,是大数据领域日志采集、流处理与数据管道的事实标准。托管版免去了 ZooKeeper 与 Broker 集群的运维负担。
有日志采集与实时数据管道需求的大数据团队;需要高吞吐事件流处理的业务;已使用 Kafka 生态希望降低运维成本的团队。
以下参数用于快速比对本产品的核心能力边界。
| 协议兼容 | Apache Kafka 协议,支持主流客户端版本 |
|---|---|
| 版本 | 支持 Kafka 2.x / 3.x |
| 吞吐 | 单实例百万级 TPS(视规格) |
| 存储 | ESSD 云盘,按需扩容 |
| 分区 | 支持数千分区 |
| 数据保留 | 支持按时间或容量保留策略 |
| 安全 | VPC 隔离、SASL 认证、SSL 加密 |
| 监控 | 提供消费延迟、堆积量、TPS 等指标 |
价格为整理时的参考区间,实际以下单页面为准。计费模式:包年包月(按实例规格) · 按量付费 · Serverless 按用量计费。
| 套餐 / 规格 | 配置说明 | 参考价格 | 备注 |
|---|---|---|---|
| 标准版 | 按实例规格 | 按量 元/小时 | 中小业务 |
| 专业版 | 高规格与高可用 | 按量 元/小时 | 生产环境 |
| 存储费用 | 按使用量 | 按量 | |
| Serverless 版 | 按吞吐与存储 | 按量 | 弹性业务 |
省钱提示:长期稳定负载优先包年包月并叠加节省计划;无状态批处理可用抢占式实例,成本可低至按量价的 10%。 查看成本优化指南 →
完全兼容 Apache Kafka 协议,现有的生产者/消费者代码、Kafka Connect、Kafka Streams 以及各类监控工具都可直接使用,迁移无需改造。
基于顺序写磁盘与零拷贝技术,单实例可支撑百万级 TPS,是处理海量日志与事件数据最高效的消息系统。
Broker 集群、ZooKeeper、磁盘扩容、分区重平衡与故障恢复全部由平台负责,业务只需关注 Topic 与消费逻辑。
作为 Flink 的标准数据源与结果表,可构建「Kafka → Flink → Hologres/MaxCompute」的实时数据管道,实现数据的实时采集、处理与入库。
消息按保留策略持久化存储,消费者可重置位点重新消费历史数据。这在数据处理逻辑出错需要重新计算时非常有用。
支持 VPC 内网访问、SASL 认证与 SSL 加密传输,也支持基于 ACL 的 Topic 级权限控制,满足多团队共享集群的安全要求。
日志采集、数据管道、流计算数据源选 Kafka;业务系统间的消息通信、事务消息、延时消息选 RocketMQ。核心区别在 Kafka 偏向「数据流」,RocketMQ 偏向「业务消息」。
分区数决定最大并行消费度。建议按预期消费吞吐量除以单消费者处理能力估算,并预留一定余量。但分区过多会增加元数据开销与重平衡时间,通常单 Topic 控制在数十个分区内较合理。
先查看是否有消费组堆积。常见原因是消费者实例数少于分区数(无法充分利用并行度),或单条消息处理耗时过长。可增加消费者实例、提高批量处理效率或优化下游写入性能。
全托管流计算引擎,流批一体处理实时数据
金融级可靠消息队列,电商交易削峰的标准选择
一站式可观测数据平台,采集、查询、告警、可视化全打通
EB 级离线数据仓库,PB 级数据分钟级处理