Kafka发送消息流程

ProducerInterceptor对消息进行拦截 Serializer对消息的key和value进行序列化 Partitioner为消息选择合适的Partition RecordAccumulator收集消息,实现批量发送 sender从RecordAccumulator获取消息 构造一个ClientRequest,这里是KafkaClient 将ClientRequest交给NetworkC
相关文章
相关标签/搜索