二 进击消息中间件系列:Kafka 单机与集群部署实践( 五 )


3.当ISR中新增分区或者减少,也会同步消息给其他的 。
重平衡机制消费策略
range指定,轮询,,range:sum(分区总数)/消费者总数+1 。
:粘合策略,如果需要,会在之前已经分配的基础上做出调整,不会改变之前的分配情况,如果没有开启该策略就会重新全部分配,效率较低,建议开启 。
HW(高水位) 作用
用HW防止数据丢失,可能副本还没有同步好的消息就被消费者消费,那么当宕机之后消息就丢失了,因为会产生新的
概念
消费者最多只能消费到HW的位置,对于新写入的消息,不能立即消费而是等待该消息被ISR集合进行同步,之后再更新HW,更新完就可以消费 。
HW取决于ISR中最小的LEO(某个副本最后消息的消息位置)——>每个完成这个消息的同步之后,HW才会变化 。
更多关于消息中间件 Kafka 系列的学习文章,请参阅:消息中间件 Kafk,本系列持续更新中 。
参考文章:
/
///
读者专属技术群
构建高质量的技术交流社群,欢迎从事后端开发、运维技术进群(备注岗位,已在技术交流群的请勿重复添加) 。主要以技术交流、内推、行业探讨为主,请文明发言 。广告人士勿入,切勿轻信私聊,防止被骗 。
扫码加我好友,拉你进群