kafka-clients源码分析二:producer发送消息架构

1. ProducerIntercptor对消息进行拦截 2. Serialzer对key和value进行序列化 3. Partitioner对消息选择合适的分区 4. RecordAccumulator收集消息,实现批量发送 5. Sender从RecordAccumulator获取消息 6 构造ClientRequest 7 将ClientRequest交给Network,准备发送 8 Net
相关文章
相关标签/搜索