一、写操作1、Kafka存储模型=分区（Partition）+日志分段（Log Segment）在Kafka中每个Topic都被分成多个分区，每个分区都是一个有序、不可变的消息日志流（只追加不修改）同时为了避免单个日志文件过大导致IO效率低

一、背景：什么时候会发生Leader选举？当Controller检测到Leader不可用的时候，会重新选举新的Leader，其中Leader不可用的原因可能如下: Leader节点宕机：检测Leader所在Broker进程异常，导致心跳超