请解释 Apache Kafka 中消息持久化的实现方式，并说明其默认的存储机制是什么？

回答思路

1. 【回答框架 1】Kafka 将每个主题分区对应一个日志目录，消息以追加写方式写入分区日志文件，日志按大小或时间滚动生成多个日志分段（LogSegment），每个分段包含一个 .log 数据文件、.index 偏移量索引和 .timeindex 时间戳索引。
2. 【回答框架 2】默认存储机制基于磁盘顺序写，利用页缓存（Page Cache）提升读写性能，消息先写入操作系统的页缓存，由操作系统决定何时刷盘，Kafka 也提供 log.flush.interval.messages 和 log.flush.interval.ms 等参数控制强制刷盘频率。
3. 【回答框架 3】索引文件采用稀疏索引，.index 文件记录相对偏移量与物理位置的映射，用于快速定位消息；.timeindex 用于按时间戳查找。日志分段达到 log.segment.bytes（默认 1GB）或 log.roll.hours（默认 168 小时）时滚动创建新分段。
4. 【回答框架 4】消息在分区内通过偏移量（offset）唯一标识，消费者通过偏移量顺序读取。Kafka 的持久化依赖副本机制，每个分区有多个副本，leader 副本负责读写，follower 副本从 leader 拉取消息并写入本地日志，保证数据冗余。
5. 【回答框架 5】清理策略支持 delete（按保留时间或大小删除旧段）和 compact（基于键保留最新值），默认保留时间为 log.retention.hours（168 小时）。
6. 【关键点 1】Kafka 消息持久化基于分区日志，采用追加写和顺序 I/O。
7. 【关键点 2】默认存储机制依赖页缓存和操作系统刷盘，可通过参数调整刷盘频率。
8. 【关键点 3】日志分段包含数据文件和稀疏索引，支持高效偏移量与时间戳查找。
9. 【关键点 4】副本机制提供数据冗余，leader 负责读写，follower 异步同步。
10. 【关键点 5】默认清理策略为按时间删除旧日志段，保留 7 天。
11. 【易错点 1】不要误认为 Kafka 默认每条消息立即刷盘，实际依赖页缓存和操作系统调度。
12. 【易错点 2】不要忽略索引的稀疏性，索引并非每条消息都有条目。
13. 【易错点 3】不要将清理策略与压缩混淆，delete 和 compact 是不同机制。