kafka API實踐（kafka原理驗證）

kafka生產者API kafka生產者發送消息採用異步發送的方式，咱們在寫發送消息的代碼的時候，會調用send方法，整個發送的過程涉及兩個線程：main線程和sender線程，有一個重要的線程共享變量：RecordAccumulator，main線程將消息放到RecordAccumulator中緩存，serder線程不斷從 RecordAccumulator中poll消息發送到 kafka（pr

>>阅读原文<<