Kafka 发送消息流程

客户端的几个组件: KafkaProducer      KafkaProducer 是一个生产者客户端的进程,通过该对象启动生产者来发送消息 RecordAccumulator   记录收集器,收集发送的消息缓存到客户端 Sender                            读取缓存,进行一些必要的转换    批量传到selector Selector               
相关文章
相关标签/搜索