Kafka的分区leader挂了后,新leader会基于已经复制的数据进行恢复,因此会基于high watermark(hw)对齐数据。因为在Kafka中,只有已经被复制的消息才会被认为是已经提交的消息,而高水位就是已经被复制的消息的最大偏移量。新leader在恢复时,会将所有follower的消息都同步到高水位之前的位置,然后再开始处理新的消息。这样可以保证数据的一致性和可靠性。

kafka的分区leader挂了后新leader是基于hw对齐数据还是基于lw对齐数据

原文地址: https://www.cveoy.top/t/topic/bQGy 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录