Kafka發送消息流程

ProducerInterceptor對消息進行攔截 Serializer對消息的key和value進行序列化 Partitioner爲消息選擇合適的Partition RecordAccumulator收集消息,實現批量發送 sender從RecordAccumulator獲取消息 構造一個ClientRequest,這裏是KafkaClient 將ClientRequest交給NetworkC
相關文章
相關標籤/搜索