kafka API實踐(kafka原理驗證)

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