2024年面试官：你说说Kafka是怎么保证消息可靠性的，大数据开发开发者必看避坑指南_kafka生产者消费者机制,消息可靠性

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，涵盖了95%以上大数据知识点，真正体系化！

由于文件比较多，这里只是将部分目录截图出来，全套包含大厂面经、学习笔记、源码讲义、实战项目、大纲路线、讲解视频，并且后续会持续更新

需要这份系统化资料的朋友，可以戳这里获取

同时如果首领副本的机器挂了，跟随者副本会选举成为新的首领副本。

分区有多个备份是消息保存的一个可靠性保障。

面试官思考中…

面试官：还有吗，比如生产者消费者呢

噢噢还有的，还有在生产者、消费者方面的可靠性。

一、在生产者方面

1. 提供了ack = all这种发送确认机制。也就是只有在消息成功写入所有副本后，才算该消息已提交，保证了消息的多备份。
2. ack = all失败的话，生产者可以继续重试发送消息。

二、在消费者方面

1. 消费者消费时，会根据偏移量进行消费，保证了消息的顺序性。
2. 消费后会同步提交、异步提交偏移量，保证了消息不被重复消费。

面试官思考中…

面试官：那要是Kafka消费堆积了怎么办

这样的话，要从Broker和消费者两方面来看。

一、Broker的话

1. 每个topic是分为多个分区给不同Broker处理，要合理分配分区数量来提高Broker的消息处理能力。比如3个Broker2个分区，可以改为3个Broker3个分区
2. 也可以横向扩展Broker集群

二、消费者的话

1. 可以增加消费者服务数量
2. 提交偏移量时，可以把同步提交改为异步提交，来减少同步等待Broker的时间

面试官思考中…

面试官：emmmm，你知道Kafka控制器吧

嗯嗯知道的。控制器其实也是一个broker，不过它还负责选举分区首领。

也就是在首领副本所在的分区失效后，通过控制器来在分区副本里选举出新的首领副本。

面试官抓抓脑袋，继续看你的简历…

得想想考点你不懂的声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：【wpsshop博客】