Kafka 是一个分布式、分区复制的提交日志(Commit Log)平台。它把消息写成只追加的顺序日志,靠分区并行与顺序写磁盘做到十万级每秒的吞吐,用副本与 ISR 保证可靠性。它最初服务于日志管道,如今是流处理、事件驱动、CDC 的事实标准。理解「分区 + 副本 + offset」这三个支柱,Kafka 就通了一大半。
1. 核心概念
| 概念 | 含义 |
|---|---|
| Topic | 消息的逻辑分类,如 order-created |
| Partition | Topic 的物理分片,是并行与有序的单位 |
| Offset | 分区内消息的唯一递增编号,消费者靠它定位进度 |
| Broker | 一个 Kafka 服务节点,多个 Broker 组成集群 |
| Replica | 分区的副本,分为 Leader 与 Follower |
| Producer / Consumer | 生产者与消费者 |
| Consumer Group | 消费者组,组内分摊分区、组间各自消费 |
2026/10/11大约 7 分钟