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

  • 相关阅读:
    记录一波三折的ViewPager与PagerAdapter
    关于加载网络图片时候 ,URL.openstream抛出异常的问题的解决
    android studio 导入第三方库的方法
    sysctl.conf优化
    SSH无需密码密钥登录
    vps添加swap
    Android之基本常见知识(持续更新)
    SSH无需密码密钥登录
    python __name__
    python code
  • 原文地址:https://www.cnblogs.com/fxjwind/p/3578887.html
Copyright © 2011-2022 走看看