浅谈大数据里的Kafka (8)Producer消息发送流程

producer到broker的消息发送流程web   Kafka的Producer发送消息采用的是异步发送的方式。在消息发送的过程当中,涉及到了两个线程——main线程和Sender线程,以及一个线程共享变量——RecordAccumulator。main线程将消息发送给RecordAccumulator,Sender线程不断从RecordAccumulator中拉取消息发送到Kafka bro
相关文章
相关标签/搜索