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

  • 相关阅读:
    WinAPI: DrawFrameControl 绘制控件
    WinAPI: SetPixel 和 SetPixelV 设置设备环境中指定位置的颜色
    WinAPI: GetSystemInfo 获取系统信息
    WinAPI: GetDiskFreeSpace 获取磁盘组织与容量信息
    WinAPI: GetDiskFreeSpaceEx 获取磁盘容量信息
    分享:Afinal 0.3.5 发布,Android快速开发框架
    海量数据多路归并排序的c++实现(归并时利用了败者树)
    当TransferEncoding遇上ContentEncoding_虚拟现实_百度空间
    chunked 编码 解码 c算法 yaneng的专栏 博客频道 CSDN.NET
    败者树 多路平衡归并外部排序 Dreaming.O的专栏 博客频道 CSDN.NET
  • 原文地址:https://www.cnblogs.com/fxjwind/p/3578887.html
Copyright © 2011-2022 走看看