订阅更新

Kafka 面试题59 道

可靠性、顺序、消费组、Rebalance、事务与幂等

全部 FlinkSparkKafka项目与面试表达Hadoop / Hive / HBaseAI 与大模型OLAP 与数据湖数仓建模SQL 与数据库数据应用：画像 / 指标 / 报表数据开发与治理Java 与 JVMPythonLinux 与运维分布式与综合
按题号 最新在前
  1. 004 Kafka 消息积压了，你怎么排查？
  2. 013 Kafka 如何保证消息不丢失？
  3. 015 Kafka Consumer 频繁 Rebalance，你怎么排查？
  4. 019 Kafka 分区数怎么设计？
  5. 022 Kafka 出现重复消费，怎么保证幂等？
  6. 026 Kafka ISR、HW 和 LEO 分别是什么？
  7. 029 Kafka 为什么吞吐量高？
  8. 032 Kafka 如何保证消息顺序？
  9. 035 Kafka Offset 怎么提交？自动还是手动？
  10. 040 Kafka acks 和 min.insync.replicas 怎么配置？
  11. 045 Kafka Consumer 越多，消费吞吐一定越高吗？
  12. 050 Kafka Retention 怎么配置？消息到期就一定删除吗？
  13. 055 Kafka 幂等 Producer 和事务 Producer 有什么区别？
  14. 060 Kafka auto.offset.reset 怎么配置？earliest 和 latest 有什么区别？
  15. 065 Kafka 分区分配策略怎么选？Range、RoundRobin 和 Sticky 有什么区别？
  16. 129 Kafka Log Compaction 是怎么工作的？
  17. 130 Kafka 零拷贝为什么能提升吞吐？
  18. 138 Kafka Leader 选举和故障恢复是怎么做的？
  19. 151 Kafka Producer 的 batch.size 和 linger.ms 怎么配？
  20. 160 Kafka Consumer Group 协调机制是怎样的？
  21. 170 Kafka KRaft 为什么替代 ZooKeeper？
  22. 179 Kafka 的 Segment 和稀疏索引如何定位消息？
  23. 193 Kafka 压缩算法怎么选？Producer、Broker 和 Consumer 谁负责？
  24. 194 Kafka 机架感知如何避免副本集中？
  25. 208 Kafka 静态成员和 Cooperative Rebalance 如何减少重平衡影响？
  26. 217 Kafka Quota 如何做多租户流量隔离？
  27. 235 Kafka 心跳正常为什么还会 Rebalance？max.poll.interval.ms 怎么配？
  28. 236 Kafka read_committed 为什么读不到最新消息？LSO 和 HW 有什么区别？
  29. 247 Kafka 扩分区为什么可能乱序？同一个 Key 还能保证顺序吗？
  30. 257 Kafka Producer 超时就代表发送失败吗？delivery.timeout.ms 怎么理解？
  31. 267 Kafka Offset 为什么不连续？Offset 差值能直接当消息条数吗？
  32. 277 Kafka 消息太大怎么处理？只调 max.request.size 够吗？
  33. 288 Kafka Topic 删除重建后，能继续使用原来的消费位点吗？
  34. 297 Kafka 历史回放怎么做才安全？换一个消费组就够了吗？
  35. 307 Kafka 消息没有 Key 会怎么分区？默认策略是每条轮询吗？
  36. 317 Kafka 消息时间就是业务发生时间吗？CreateTime 和 LogAppendTime 怎么选？
  37. 327 Kafka max.poll.records 调小就能防 OOM 吗？Poll 和 Fetch 有什么区别？
  38. 340 Kafka Consumer 调用 seek 后，消费组的提交位点也会改变吗？
  39. 348 Kafka Producer 调用 flush 就算全部成功了吗？和事务提交有什么区别？
  40. A1 Kafka 的 acks 机制：0、1、all 分别意味着什么？
  41. 06-01 3个Broker、12个Partition够不够？——聊聊你们Kafka集群怎么规划的
  42. 06-02 广告归因数据丢了一条，ROI算错了——Producer的acks到底怎么配？
  43. 06-03 Flink消费Kafka突然全停了，Doris大盘一片空白——Rebalance怎么排查？
  44. 06-04 晚高峰送礼消息堆了50万条，Doris大盘延迟5分钟——消费积压怎么办？
  45. 06-05 日均12亿条消息不在话下——Kafka为什么比数据库快100倍？
  46. 06-06 一台Broker凌晨挂了，消息还在不在？——副本机制和ISR详解
  47. 06-07 消息不丢不重真的能做到吗？——Exactly-Once语义全链路拆解
  48. 06-08 FlinkCDC → Kafka → Flink → Doris，实时数仓这条链路怎么设计最稳？
  49. 06-09 用户先下单后付款，消费到的顺序反了——Kafka消息有序性怎么保证？
  50. 06-10 一个项目该建几个Topic？——Topic设计与Kafka集群运维实战
  51. 06-11 JSON太大Avro看不懂——消息格式到底选哪个？
  52. 06-12 凌晨3点报警响了——Kafka集群监控哪些指标必须盯？
  53. 06-13 某个Partition消息量是其他的10倍——Kafka数据倾斜怎么解决？
  54. 06-14 Kafka vs RocketMQ vs RabbitMQ——为什么大数据几乎都选Kafka？
  55. 06-15 埋点数据从SDK到数仓，中间Kafka这段链路怎么保证数据质量？
  56. 06-16 吞吐上不去延迟降不下来——Kafka性能调优参数全攻略
  57. 06-17 用户在纽约发的消息，北京收到的时间差了13小时——Kafka跨时区数据怎么处理？
  58. 06-18 不写代码也能同步数据？——Kafka Connect和生态工具全解析
  59. 06-19 谁都能连上来读写数据？——Kafka安全认证和权限控制