一、kafka是如何保证消息不丢失

1. 介绍

• 使用kafka在消息的收发过程都有可能会出现消息丢失
  （1）生产者发送消息到broker丢失
  （2）消息在broker中存储丢失
  （3）消费者从broker接收消息丢失
  

2. 生产者发送消息到broker丢失

• 设置异步发送：同步发送会发生阻塞，一般使用异步发送方式发送消息
  
• 消息重试：由于网络抖动，造成消息发送失败，可以使用kafka提供的重试机制
  

3. 消息在broker中存储丢失

• broker存储大体流程
  （1）生产者发送消息到达broker中
  （2）消息存储在分区中，分区分为两个不同角色，leader只有一个，follower可能会有多个
  （3）先把消息保存到leader分区中，然后由leader将消息同步到follower中
  
• 发送确认机制acks
  （1）要想保证数据不丢失，可以设置acks=all，在所有分区副本保存完成后，才会发送确认给生产者，性能也是最低的
  （2）实际生产环境中，最低也要设置acks=1
  

4. 消费者从broker接收消息丢失

• 一个kafka集群是由多个broker（kafka实例）组成的
• 每一个broker中都存在不同的topic，并且一个topic可能存在多个分区，这些分区可能存在不同的broker中
• 一个消费者组可能存在多个消费者，它们都是消费同一个topic，负责消费topic不同分区
• topic分区中消息只能由消费者组中唯一一个消费者处理，不同的分区分配给不同的消费者
  
• 丢失消息原因
  （1）消费者默认是自动按期提交已经消费的偏移量，默认是每隔5秒提交一次。如果消费者组出现重平衡的情况，可能会重复消费或者丢失消息
  （2）可以禁用自动提交偏移量，改为手动
  
• 解决方案
  （1）同步提交【会阻塞，不推荐】
  （2）异步提交【偏移量可能不准确，不推荐】
  （3）同步+异步组合提交【推荐】
  

5. 总结

6. 参考答案

二、kafka是如何保证消息的顺序性

1. 介绍

• 问题原因
  （1）一个topic中的数据可能存储在不同的分区中，每个分区都有一个按照顺序的存储偏移量，如果消费者关联了多个分区，则不能保证消费的顺序性
• 解决方案
  （1）发送消息时，指定分区号，往同一个分区中存储消息
  （2）发送消息时，按照相同的业务设置相同的key
  

2. 案例分析

• springboot集成kafkatemplate
  

3. 参考答案

三、kafka的高可用机制要了解过吗

1. 介绍

• 集群模式
• 分区备份机制

2. 集群模式

3. 分区备份机制

4. 总结

5. 参考答案

四、kafka数据清理机制有了解过吗

1. 介绍

• kafka文件存储机制
• 数据清理机制

2. kafka文件存储机制

3. 数据清理机制

4. 总结

5. 参考答案

五、kafka中实现高性能的设计有了解过吗

1. 介绍

2. 参考答案