Please enable JavaScript.

Coggle requires JavaScript to display documents.

ELK, Kafka, Elasticsearch, Kafka中采用了分区器(Partitioner)来为我们进行分区路由的操作。本文将详细讨论K…

- - - - Message (物理資料)
        
        每條擁有ID編號的信息又稱 Offest
- - - - Leader
        分割為雙數以上可設定偏好Primary partition在哪一Broke上
        如主分片Broker故障將會透過選舉機制選出下一個擁有分片副本的Broker接替 Primary partition 因此諾有過多的分割將會降低選舉效率
      - Partition的訊息儲存機制
        
        ProducerRecord
        
        Serializer
        
        Partitioner
        
        roundrobin
        
        https://segmentfault.com/a/1190000021824942
        
        https://blog.csdn.net/Dongguabai/article/details/86536894
      - Replication
        只負責與分區Leader同步資料
        不會負責處理生產與消費者請求
        除非分區Leader發生故障
      - 一個Partition分為Segment(物理資料)
        一個Segment下由兩個檔案組成
        .index & .log
        
        .Index
        “.index”檔案儲存大量的索引資訊
        
        .log “.log”檔案儲存大量的資料，索引檔案中的元資料指向對應資料
        
        Message
- - - - Replication
      - Primary