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去除

  • 相关阅读:
    Ubuntu下虚拟机卡顿
    C函数重载
    ACPI电源状态定义
    /dev/random生成随机数慢的问题
    GCC强制静态库链接未使用的函数、变量
    cmake交叉编译问题
    cmake语法
    CentOS安装OpenOCD
    LOJ3119. 「CTS2019 | CTSC2019」随机立方体 二项式反演
    BZOJ4710 [Jsoi2011]分特产 容斥
  • 原文地址:https://www.cnblogs.com/fxjwind/p/3578887.html
Copyright © 2011-2022 走看看