1. Kafka是一个分布式流处理平台：
- 可以让你发布和订阅流式的记录。这一方面与消息队列或者企业消息系统类似。
- 可以储存流式的记录，并且有较好的容错性。
- 可以在流式记录产生时就进行处理。
2. 消息系统：
定义
- 将数据从一个应用程序传递到另一个应用程序，通过提供消息传递和消息排队模型，它可以在分布式环境下扩展进程间的通信。
- 分布式系统利用消息系统，在多应用之间进行高效、稳定、安全的数据传递。
- 应用场景有跨系统数据传递、高并发流量削峰、数据异步处理。
两种消息模式：
- 点对点：若干个生产和消费者，处理队列当中的数据，一旦该数据被消费，则从队列当中被移除。（多线程：生产消费者模型）
- 发布-订阅：消息是被保留在主题当中，消费者一个消费一个或者若干个主题当中的消息
3. kafka的一些概念
1. 术语：
| 术语 | 术语 |
|---|---|
| Topics（主题） | Kafka Cluster（Kafka集群） |
| Partition（分区） | Producers（生产者） |
| Partition offset（分区偏移） | Consumers（消费者） |
| Replicas of partition（分区备份） | Leader（领导者） |
| Brokers | Follower（追随者） |
2. 发布和订阅的流程
- 生产者向topic当中提交消息，Brokers将topic当中的数据在对应的分区当中依次保存；
- 消费者向Brokers请求获取消息，Brokers向消费者提供偏移量，消费者根据偏移量要求获取消息。
- 消费者排队的前提，消费者数量大于分区数量
- 同一个消费者组内的消息不会重复消费。
3. 生产者：
主要是消息提供者，根据业务需要往指定的topic推消息，一般也俗称为消息的上游。
4. 消费者：
- 要指定消费者的分组：默认情况下，分组是test
- 消费者可以同时消费若干个topic：
- 消息是已key-value格式进行发送
- 每个key如果重复发送，其偏移量会递增
- 新key的偏移量从0开始
- 消费者要放在一个独立的线程当中，才能始终处于消费状态
- Spring是没有办法直接给线程当中进行依赖注入的
- 消费者的线程如果要通知其他的任务执行，需要从Spring的bean当中获取相关的业务对象
5. kafka写消息的路由策略
- 如果指定分区：直接使用分区进行路由
- 指定了key，但是没有指定分区，那么会对key进行hash运算，通过运算的值得到一个分区
- 如果都没指定，那么会轮询写入一个分区
6. kafka写硬盘：
- 传统写硬盘是随机写
- kafka是顺序写硬盘，是随机写硬盘速度的6000倍
- 写数据的流程
- 首先找到leader
- 将消息写入leader的日志文件
- Followers(包含ISR中的成员，也包含不在ISR中的成员)会同步leader当中的消息，同步完以后会向leader发送一个ACK确认。
- leader在接收到isr所有成员的ACK确认后，正式提交commit保存
7. kafka的消息安全策略：
- 默认是保证一定成功（同步）
- 不重复发送，不保证成功（异步）
8. kafka的备份：
- 备份是由分区来创建的
- 一个分区有1个leader和0-n个follower，只要leader不宕机，所有的follower都宕机了也不影响读写。follower只负责数据备份，不负责数据读写。
9. Kafka的isr：
- 同步备份：保证isr集合当中至少存活一个，如果leader不挂，正常提供服务，如果leader挂了，重新选leader然后提供服务；每个分区都有自己的isr
1. 备份的算法： 1. 分区：分区编号，取余代理数量 （p_i mod b_num） 2. 备份：分区编号 + 备份编号之和， 取余 代理数量（p_i+r_j） mod b_num
- 判定存活：配置延时replica.log.max.messages，replica.log.time.max.ms来判定是否宕机
- kafka如何解决zookeeper的压力的
- Kafka有容器机制
- 每一个代理会创建一个新的容器
- 容器负责维护leader的读写，和选举
- leader是在zk上竞争创建节点来获取leader资格，如果leader宕机，选举策略是所有的follower（ISR当中保存的成员）重新竞争创建节点，获取leader资格；容器会记录新的leader，并保持
- 如果所有的ISR成员都死亡：
- 等待ISR成员任意一个苏醒，但是这个过程是不可控的
- 默认：只要有一个不是isr的成员存活，把这个作为新的leader。但是并不能保证这个成员是否数据和原本leader数据一致。
10. kafka的数据保存：
- Kafka的日志分为两种，一种是运行日志；还有一种是用于保存消息的日志；
- 一个分区对应日志当中的一个目录
- 索引文件
- 数据文件
- 数据长度
- 数据类型
- 时间戳
- 偏移量
- Key
- Value
- 头信息
- 数据保留策略
- 时间：
- 大小：
- 注意：清理数据对kafka的读写没有任何影响
- Kafka是在硬盘磁道上进行顺序读写，所以性能和文件大小没有任何关系
11. topic的创建和删除流程：
- 创建topic，是首先获取代理的ids，然后将这些ids组成一个isr，作为一个新的容器
- 删除topic：
- 默认情况下delete.topic.enable=false；也就是被删除的节点会被移入zk的这个节点/admin/delete_topics
- 要彻底删除
- delete.topic.enable=true：一旦删除，容器会清空在/admin/delete_topics节点上的监听
- auto.create.topics.enable=false：自动创建主题，如果他为true，那么只要还有一个用户在往这个主题当中写消息，这个主题就不会真正被删除。即便是你已经删了，他依然还会创建一个出来。
