zoukankan      html  css  js  c++  java
  • Apache Kafka源码分析 – Replica and Partition

    Replica

    对于local replica, 需要记录highWatermarkValue,表示当前已经committed的数据
    对于remote replica,需要记录logEndOffsetValue以及更新的时间

     

    Partition

    主要用于管理leader,ISR,AR

    getOrCreateReplica


    makeLeader

    maybeIncrementLeaderHW
    用所有remote replica的LEO的最小值来替换当前的HW(如果大于HW的话)


    makeFollower


    maybeShrinkIsr

    从ISR中将Stuck followers和Slow followers去除

  • 相关阅读:
    牛客小白月赛21
    牛客小白月赛21
    CodeForces 1333-C Eugene and an array(子区间和为0、前缀和)
    页面大小、页表项、虚拟地址和物理地址之间的关系(转)
    001-Paint_FreePythonGames项目代码详解(每行都有注释!!!)
    第17讲~第19讲:函数:python的乐高积木
    第16讲:序列!序列!
    第15讲:字符串格式化
    练习23--字符串、字节和编码
    第14讲:字符串--各种奇葩内置方法
  • 原文地址:https://www.cnblogs.com/fxjwind/p/3578887.html
Copyright © 2011-2022 走看看