kafka之生產者

一、通訊過程    生產者、消費者看作客戶端，消息代理看作服務端，它們之間的網絡通訊如下： 二、概念 1、生產者發送過程：生產者要發送消息，並不是直接發送給服務端，而是先在客戶端把消息放入隊列中， 然後由一個消息發送線程從隊列中拉取消息，以批鹽的方式發送消息給服務端。 2、記錄收集器（RecordAccumulator）：負責緩存生產者客戶端產生的消息（批記錄隊列），批記錄沒有滿，需要等待直到收集

>>阅读原文<<