Please enable JavaScript.

Coggle requires JavaScript to display documents.

Kafka简介 - Coggle Diagram

- - - - :envelope_with_arrow:将军身处各地需要信差传递消息
        
        服务器通过网络通信
      - 存在叛徒、间谍
        
        某些服务器失效
      - 发生战争所有将军需要达成共识
        
        分布式服务器集群对外服务保持一致
  - - - A Raft Protocol for the Metadata Quorum
      - Replace ZooKeeper with a Self-Managed Metadata Quorum
  - - - 角色
        
        :man_in_tuxedo:Leader
        
        :boy::skin-tone-2:Candidate
        
        :baby:Follower
      - 任期Term
        
        单调递增 1,2,3
        
        一个任期内最多一个Leader，获取超半数投票者
        
        任期号小，leader变回follower
      - :heartbeat:心跳
        
        :speaking_head_in_silhouette:leader任期内广播心跳包，昭告自己的存在
        
        follower收到心跳包后，将选举定时器清零
      - :alarm_clock:选举定时器
        
        :symbols:随机重试
        
        :dagger_knife:超时，意味着leader可能挂了，重新开始选举
        
        leader广播心跳周期小于超时时间
    - - 复制内容
        
        :bookmark_tabs:Append Entries RPC
        
        term
        
        command
        
        log index
      - 复制流程
        
        客户端向Leader发送请求
        
        Leader将请求追加到本地日志文件，广播给每个Follower
        
        Follower进行一致性检查，追加Leader的日志条目，并通知Leader
        
        超半数节点已追加日志条目，则Leader commit该日志条目
        
        Leader通知Follower commit日志条目
        
        Leader返回操作结果给客户端
- - - - :family:Consumer Group
    - - Partition
        
        Replica
        
        Leader
        
        Follower
        
        Record
        
        :old_key:Key
        
        Value
        
        Offset
  - - - Range
      - Sticky
        
        分区尽可能均衡
        
        尽可能与上次分配相同
      - Round Robin
    - - At most once 最多一次，消息可能会丢失，但不会重复
      - At least once 最少一次，消息不会丢失，可能会重复
      - Exactly once 只且一次，消息不丢失不重复
      - 默认每五秒自动提交，以上语义都不能满足