面试官:听说你精通Kafka,那我就考考你吧面试官:不用慌尽管说,错了也没关系😊。。。__以【面试官面试】的形式来分享技术,本期是《Kafka系列》,感兴趣就关注我吧❤️
当前高水位就是复制偏移量嘛,记录了当前已提交消息的最大偏移量。
是这样的,Kafka的消息只有在所有分区副本都同步该消息后,才算是已提交的消息。
分区副本会根据首领分区副本提供的高水位,来避免未提交的消息被消费。
面试官思考中…
嗯嗯好的。
在Broker方面,主要使用了分区多副本架构,来保证消息不丢失。
Kafka集群的每一个分区的首领副本,都会有n(复制系数)个broker机器去复制后,生成跟随者副本。
同时如果首领副本的机器挂了,跟随者副本会选举成为新的首领副本。
分区有多个备份是消息保存的一个可靠性保障。
面试官思考中…
噢噢还有的,还有在生产者、消费者方面的可靠性。
一、在生产者方面
二、在消费者方面
面试官思考中…
这样的话,要从Broker和消费者两方面来看。
一、Broker的话
二、消费者的话
面试官思考中…
嗯嗯知道的。控制器其实也是一个broker,不过它还负责选举分区首领。
也就是在首领副本所在的分区失效后,通过控制器来在分区副本里选举出新的首领副本。
面试官抓抓脑袋,继续看你的简历......得想想考点你不懂的😰
好了,今天的分享就先到这,我们下期【Kafka系列】继续。
创作不易,不妨点赞、收藏、关注支持一下,各位的支持就是我创作的最大动力❤️
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。