Kafka 实战
第1章 Kafka 核心概念与架构1.1 Kafka 是什么Apache Kafka 是一个分布式事件流平台(Distributed Event Streaming Platform),最初由 LinkedIn 于 2011 年开源,后成为 Apache 顶级项目。Kafka 的核心定位可以用三个关键词概括:高吞吐、可持久化、分布式。2025 年 3 月,Apache Kafka 正式发布 4.0 版本,彻底移除了依赖十年的 ZooKeeper 组件,全面启用 KRaft(Kafka Raft)模式,标志着 Kafka 进入了真正的"自治式分布式系统"时代。Kafka 的三大核心功能:消息队列功能:作为发布/订阅消息系统,生产者将消息发布到 Topic,消费者订阅 Topic 接收消息,实现系统解耦。容错的持久化存储:消息持久化到磁盘,按 Partition 和 Offset 组织,支持可配置的保留策略。流式处理能力:通过 Kafka Streams API 提供完整的流式处理类库,支持实时过滤、聚合、关联等操作。典型应用场景:场景说明