Kafka HW及Epoch
引用:HW与Epoch的讨论HW存在的意义:(为了保持副本间可消费数据一致的标记)保证多个副本之间的数据一致,否则因为同步的延迟的问题会出现多个副本间数据不一致的问题。如果Leader重新选举,对于消费者来说还会出现跳跃消费数据,丢失数据的情况保证当出现Leader切换后,能够消费的数据一致HW存在的基础:LEO 日志末端位移,表示日志末端下一条数据的位移,如果它的值为10那么分区中存在0~9 10条数据,下一条的位移量是10怎么样更新HW简单的说:取LEO的最小值,就是保证所有的副本.