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

  • 相关阅读:
    Create a toolwindow for the VBA editor with .NET(C#).
    批量采集世纪佳缘会员图片及winhttp异步采集效率
    写了一个Windows API Viewer,提供VBA语句的导出功能。提供两万多个API的MSDN链接内容的本地查询
    mysql主从复制
    windows实现MySQL主从复制
    理解“业务逻辑”的含义
    数据库主从复制与读写分离(了解)
    windows下npm安装vue
    phpstorm中配置真正的远程调试(xdebug)
    PHP常量详解:define和const的区别
  • 原文地址:https://www.cnblogs.com/fxjwind/p/3578887.html
Copyright © 2011-2022 走看看