1. Kafka面试全景与能力模型

很多候选人准备Kafka面试时，第一反应是背“零拷贝”“ISR”“分区副本”这些名词，结果面试官一句“你线上遇到过消息积压吗？怎么定位的？”就露了底。Kafka面试真正的分水岭，不在于你记得多少概念，而在于你能否把概念放进一条完整的因果链里：数据怎么进来、怎么存、怎么被消费、出问题时怎么查、怎么权衡。本章先帮你把整张地图铺开，再给出可执行的备考路径。

一、高频考点分布：面试官到底在考什么

把近三年一线互联网公司Kafka相关面试题做聚类，大致落在五个层次上，难度和区分度依次上升：

从出现频率看，消息积压、重复消费、消息丢失、Rebalance、ISR这五类问题几乎覆盖了中高级岗位80%的追问。它们共同指向一个能力：把“现象—指标—根因—处置—验证”串起来讲清楚。

二、岗位能力模型：不同级别要求不同

同样是Kafka，初级、中级、高级的答法完全不同。初级能说清“是什么、怎么用”；中级要能说清“为什么、怎么调”；高级必须能说清“怎么权衡、怎么兜底”。

• 初级（1–3年）：会用客户端API，理解分区与消费者组，能写生产者/消费者示例，知道offset提交的自动与手动区别。
• 中级（3–5年）：能根据业务估算分区数，能读懂Lag监控，能处理Rebalance与重复消费，理解acks、min.insync.replicas对可靠性的影响。
• 高级（5年以上）：能设计跨机房容灾、Exactly-Once链路，能定位ISR抖动与PageCache压力，能在吞吐、延迟、成本之间给出量化取舍。

面试时最忌讳“越级硬答”。如果你只有两年经验却大谈事务隔离级别实现，反而容易被追问到崩。策略是：把当前级别的问题答到闭环，再顺势展示一层深度。

三、答题策略：用“闭环结构”代替名词堆砌

以“消息积压”为例，一个能拿高分的回答不是“加消费者”，而是这样展开：

现象：消费Lag持续上涨，从5万涨到200万，持续30分钟
定位：先看是生产突增还是消费变慢——对比生产TPS与消费TPS曲线
     再看消费者是否卡在Rebalance，或单条处理耗时变长（如下游DB慢查询）
根因：下游接口P99从80ms涨到1.2s，单线程消费吞吐从1200条/s降到80条/s
处置：短期扩容消费者到分区数上限，同时下游限流降级
     中期把批量消费batch.size调大、开启异步处理
验证：Lag在15分钟内回落到1万以内，消费TPS恢复到1500条/s

注意这里每个数字都是示例参数，用于说明表达结构，不是实测结果。面试中你应替换成自己项目的真实量级。这种“现象—指标—根因—处置—验证”的闭环，比背十个名词更能证明你做过。

四、30节学习路径：从会用走向能扛

整个课程按“基础—机制—实战—架构”四段推进，建议按顺序学，每节配套一道高频题：

每学一节，建议做三件事：用自己的话复述机制、写出一个可运行的验证示例、准备一个真实或假设的排障故事。例如学完分区与副本后，可以在本地起一个3 Broker集群，创建replication.factor=3的Topic，手动kill一个Broker，观察Leader切换与ISR变化，再用kafka-topics.sh --describe确认结果。这种“动手—观察—判断”的过程，才是面试时能脱口而出的底气。

五、可直接使用的备考检查表

下面这份清单可作为你每节学习后的自检工具，字段和判断标准都围绕Kafka面试场景设计：

把这五栏都打上勾，你对该节的掌握就达到了可面试的水平。接下来，我们从最基础也最容易被低估的Topic与Partition开始，逐层深入。