1. 基本概念
角色主题、分区副本
HW、LEO 容灾概述
发送端消费端
1. 基本概念 角色一个典型的 Kafka 体系架构包括：
若干 Producer若干Broker（集群）：一般情况下，一台kafka实例就是一个broker若干 Consumer一个ZooKeeper集群：负责集群元数据的管理、控制器的选举 主题、分区
主题是逻辑上的概念，发送消息时只需要指定主题，分区是用来负载均衡的，用户不需要指定主题下有多个分区，一个分区只属于单个主题，分区可以分布在不同的broker上，也就是说，一个主题可以横跨多个broker，大大提高性能同一主题下的不同分区包含的消息是不同的分区的实现是一个可追加的log消息在被追加到分区日志文件的时候都会分配一个特定的偏移量（offset）：offset是消息在分区中的唯一标识，Kafka通过它来保证消息在分区内的顺序性。可以类比数组的索引。offset只在当前分区生效，也就是说，默认情况下Kafka保证的是分区有序而不是主题有序。
副本大部分常见的消息队列都是这样，因为保证topic全局顺序性能太低
包括leader和follower副本
分区中的所有副本统称为AR（Assigned Replicas）所有与leader副本保持一定程度（可通过参数配置）同步的副本（包括leader副本在内）组成ISR（In-Sync Replicas）与leader副本同步滞后过多的副本（不包括leader副本）组成OSR（Out-of-Sync Replicas）AR=ISR+OSR；正常情况下，AR=ISR HW、LEO
HW=High Watermark.消费者只能拉取到这个offset之前的消息
LEO=Log End Offset.标识当前日志文件中下一条待写入消息的offset
读取（消费）：取ISR中同步offset的最小值，即一条消息要在ISR内所有副本之间写入完才可以被读取
写入：无限制
这种方式在数据可靠性和性能之间取平衡
一主多从结构+选举机制，leader副本负责处理读写请求，follower副本只负责与leader副本的消息同步；leader副本挂掉就从ISR中选举
消费端Consumer 使用拉（Pull）模式从服务端拉取消息，并且保存消费的具体位置，当消费者宕机后恢复上线时可以根据之前保存的消费位置重新拉取需要的消息进行消费，这样就不会造成消息丢失。
