kafka 生產者 API

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