kafka在zookeeper数据结构
controller选举
客户端同时往zookeeper写入, 第一个写入成功(临时节点), 成为leader, 当leader挂掉, 临时节点被移除, 监听机制监听下线,重新竞争leader, 客户端也能监听最新leader
leader partition自平衡
leader不均匀时, 造成某个节点压服务器托管网力过大, 达到阈值时, 会触发自平衡, 均匀分配leader, 默认服务器托管网头节点
partition故障恢复机制
Leo:每个Partition的最后一个Offset
HW:一组Partiton中最小的LEO
HW一致性保障
当Leader切换时, 可能产生HW不一致 ,Kafka设计Epoch保证HW一致性
服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net
相关推荐: 让 sdk 包静默升级的 SAO 操作，你见过几种？
拓展阅读 让 sdk 包静默升级的 SAO 操作，你见过几种？ 业务背景 有时候为业务方提供了基础的 sdk 包，为了保证稳定性，一般都是 release 包。 但是每一次升级都非常痛苦，也不可能写一个一步到位的 jar 包，因为业务一直在变化。 那有什么方式…
