在 producer client 端，producer 會維護乙個concurrentmap> batches的變數，然後會根據 topic-partition 的 leader 資訊，將 leader 在同一臺機器上的 batch 放在乙個 request 中，傳送到 server，這樣可以節省很多網路開銷，提高傳送效率。
producer client 傳送請求的方法實現如下：
kafka接收到producer請求後，通過其網路模型，最終會交給kafkaapis元件處理
replicamanager，副本管理器，作用是管理這台 broker 上的所有副本（replica）。在 kafka 中，每個副本（replica）都會跟日誌例項（log 物件）一一對應，乙個副本會對應乙個 log 物件。
replicamanager 的並不負責具體的日誌建立，它只是管理broker上的所有分割槽。在建立 partition 物件時， partition 會通過logmanager 物件為每個 replica 建立對應的日誌。
replicamanager拿到請求內容後，主要做了如下事情:
parititon元件從replicamanager拿到訊息後
log物件是對partition資料目錄的抽象。管理著某個topic在某個broker的乙個partition,它可能是乙個leader，也可能是replica。同時，log物件還同時管理著多個logsegment，也就是日誌的分段。
在 log 物件的初始化時，有三個變數是比較重要的：
從 mayberoll() 的實現可以看到，是否需要建立新的日誌分段，有下面幾種情況：
建立乙個 segment 物件，真正的實現是在 log 的roll()方法中，建立 segment 物件，主要包括三部分：資料檔案、offset 索引檔案和 time 索引檔案。
這裡順便講述一下 offset 索引檔案，kafka 的索引檔案有下面幾個特點：
kafka底層的寫資料是根據filechannel來寫的，它寫的時候不會立刻刷盤，而是開啟了乙個定時任務根據策略去刷盤。但是在預設情況下，這個定時任務又是不刷盤的（刷盤策略都不滿足），kafka把刷盤的時機交給作業系統來掌控。
kafka學習 produce訊息
由於歷史原因，我們公司用的還是比較老的kafka版本0.10.1.0，最近由於專案需要，學習了kafka的使用，學習過程中了解到的一些知識記錄下，以便日後查閱 目錄 kafka學習 produce訊息 1.broker topic partition 2.傳送訊息分割槽選擇 3.資料報格式 4.go...
Kafka 客戶端 Produce 常用配置
配置類值作用 demo org.apache.kafka.clients.commonclientconfigs bootstrap servers config bootstrap.servers 配置kafka 伺服器位址資訊 localhost 9092，localhost 9092 org....
對server 返回的時間的封裝處理
根據專案要求，需要將server返回的時間資料進行處理，server 返回的時間格式為 2016 07 06 13 00 1，今天的話 要求為 今天 13 00 2，昨天的話 要求為 昨天 13 00 3，昨天以前 要求為 7月6日 13 00 要求 不准出現 07月06日 13 00 即如果月日前...