Kafka mindmap
基础
- 消息队列的消息模型有哪些？
- Kafka 的架构是什么样的？
- Kafka 的应用场景有哪些？
- Kafka 的优缺点有哪些？选型问题？
- Kafka 为什么性能高？
- Kafka 如何保证可用性？
- Kafka 如何负载均衡与故障转移？TODO
- Kafka 的吞吐量如何提升？
- Kafka 中 Zookeeper 的作用
- Kafka 架构从 ZooKeeper 切换到 KRaft 后的变更
- Kafka 缓冲区满了怎么办？
- Kafka 数据一致性原理
- Kafka 限流机制
消息
- Kafka 消息是如何存储到磁盘中？(数据存储原理)
- Kafka 消息有序是如何实现的？
- Kafka 消息丢失的原因？怎么验证？怎么解决？(理论+业务角度)
- Kafka 消息重复消费是什么原因？怎么解决？(理论+业务角度)
- Kafka 消息堆积是什么原因？怎么解决？(理论+业务角度)
- Kafka 消息是否丢失，该如何检查？
- Kafka 消息消费重试机制
- Kafka 消息什么时候适合数据压缩？有哪些压缩方法？
- Kafka 消息如何实现 exactly once？
- 数据传输的事务有几种？消息传输语义？
- 什么情况下，机器扩容后消费者 TPS 没变化？
分区
- Kafka 分区的目的
- Kafka 分区数目越多越好吗？
- Kafka 生产者分区策略 & 消息分区分配策略
- Kafka 创建Topic后如何将分区放置到不同的Broker中
- Kafka 为什么存在分区的不均衡？怎么解决？
- Kafka 为什么存在消息的数据倾斜？怎么解决？
副本
- Kafka 副本中 Replica、Leader、Follower 三者的概念
- Kafka 副本一定是负载均匀分布吗？是否存在一台机器多个副本情况？
- Kafka 副本支持读写分离吗？为什么？
- Kafka 副本中 AR、ISR、OSR 三者的概念
- Kafka 副本的分区 Leader 是如何选取的？(ZK)
- Kafka 副本中元数据一致性如何保证？(KRaft)
- Kafka 副本 Leader 宕机时，Follower 没同步完成，数据丢失怎么办？
生产者
消费者
- Kafka 消费模式是拉还是推？
- Kafka 消费者与消费者组的关系与负载均衡实现
- Kafka 消费者组重平衡是什么？时机？弊端？避免？
- Kafka 消费者组重平衡过程
- Kafka 消费者故障导致活锁，怎么解决？
- Kafka 消费者位移存放在哪里？
- Kafka 消费者端位移提交方式有哪些？(Java)
- Kafka 消费者事务性提交
日志
- Kafka 日志保留期与数据清理策略
- Kafka 日志存储的Message是什么格式？
- Kafka 日志分段策略与刷新策略
- Kafka 日志 LEO、HW、LSO、LW 等分别代表什么？
- Kafka 日志 LEO、HW 更新机制是怎么样的？
ZK 下的控制器
KRaft 下的 Leader
其他
分布式事务
- topic 怎么决定写哪个？consumer 怎么知道读哪个？
- Kafka 的延时消息
- kafka 时间轮片