淺談大數據裏的Kafka (8)Producer消息發送流程

producer到broker的消息發送流程web   Kafka的Producer發送消息採用的是異步發送的方式。在消息發送的過程當中,涉及到了兩個線程——main線程和Sender線程,以及一個線程共享變量——RecordAccumulator。main線程將消息發送給RecordAccumulator,Sender線程不斷從RecordAccumulator中拉取消息發送到Kafka bro
相關文章
相關標籤/搜索