Kafka源码之KafkaProducer分析

我们先通过一张图来了解一下KafkaProducer发送消息的整个流程: 1、ProducerInterceptors对消息进行拦截。 2、Serializer对消息的key和value进行序列化 3、Partitioner为消息选择合适的Partition 4、RecordAccumulator收集消息,实现批量发送 5、Sender从RecordAccumulator获取消息 6、构造Clie
相关文章
相关标签/搜索