【面试官】你说说Kafka是怎么保证消息可靠性的

• 面试官：知道Kafka高水位吗？
• 面试官：你说说Kafka是怎么保证消息可靠性的？
• 面试官：还有吗，比如生产者消费者呢？
• 面试官：那要是Kafka消费堆积了怎么办？
• 面试官：emmmm，你知道Kafka控制器吧？

• 👉以【面试官面试】形式覆盖Java程序员所需掌握的Java核心知识、面试重点
• 📚本期是《Kafka系列》，其他系列博客请订阅专栏《Java Offer训练营》
• ❤创作不易，不妨点赞、收藏、关注支持一下

文章目录

1. Kafka高水位
2. Kafka消息可靠性
   1. 生产者消费者可靠性
   2. 消费堆积
3. Kafka控制器

1. Kafka高水位

面试官：知道Kafka高水位吗？

当前高水位就是复制偏移量，记录了当前已提交消息的最大偏移量。

是这样的，Kafka的消息只有在所有分区副本都同步该消息后，才算是已提交的消息。

分区副本会根据首领分区副本提供的高水位，来避免未提交的消息被消费。

2. Kafka消息可靠性

面试官：你说说Kafka是怎么保证消息可靠性的？

好的。

在Broker方面，主要使用了分区多副本架构，来保证消息不丢失。

Kafka集群的每一个分区的首领副本，都会有n（复制系数）个broker机器去复制后，生成跟随者副本。

同时如果首领副本的机器挂