Apache Kafka 是一个分布式流数据平台，用于高吞吐量、持久性、可扩展的发布和订阅消息。它具有高度的可靠性，被广泛用于构建实时数据流处理、日志收集和数据管道等应用。
基本架构
1. 主题（Topic）：
- 主题是消息的逻辑分类
- 生产者将消息发布到特定的主题中，而消费者可以订阅一个或多个主题来接收消息
- 主题可以有多个分区，以实现横向扩展和负载均衡
2. 分区（Partition）：
- 分区是主题的物理存储单元，将主题分成多个部分
- 每个分区在磁盘上都有一个日志文件，用于持久性存储消息
- 每个主题可以被分为多个分区，每个分区都是一个有序的、不可变的消息序列
- 分区可以分布在不同的 Broker 上，以实现数据的并行处理和负载均衡
3. 副本（Replica）：
- Kafka 支持副本机制，每个分区可以有多个副本，其中一个是领导者（Leader），其余是追随者（Follower）
- 主副本负责处理读写请求，而从副本只负责复制主副本的数据
- 副本是分区的备份，用于提供冗余和容错性
4. 生产者（Producer）：
