Apache Kafka保证数据的持久性和可靠性主要通过以下几个机制：
1、日志存储：
- Kafka将所有消息持久化到磁盘。这意味着即使发生系统故障，消息数据也不会丢失。
- 每个消息在被认为已经“提交”（Committed）之前都会被写入磁盘。
2、分区复制（Replication）：
- Kafka中的每个分区都可以有一个或多个副本，这些副本分布在不同的Broker上。
- 有一个副本会被指定为Leader，其余的作为Follower。所有的读写操作都是通过Leader进行的，而Follower则从Leader复制数据。
)
