Kafka(内部详解)如何保证数据的一致性

数据一致性保证 一致性定义：若某条消息对client可见，那么即便Leader挂了，在新Leader上数据依然能够被读到 HW-HighWaterMark: client能够从Leader读到的最大msg offset，即对外可见的最大offset， HW=max(replica.offset) 对于Leader新收到的msg，client不能马上消费，Leader会等待该消息被全部ISR中的re

>>阅读原文<<