kafka 笔记二 kafka生产者

Kafka数据生产流程解析 1. Producer 创建时，会创建一个 Sender线程并设置为守护线程。 2. 生产消息时，内部其实是异步流程；生产的消息先经过拦截器 -> 序列化器 ->分区器，然后将消息缓存在缓冲区（该缓冲区也是在 Producer创建时创建）。 3. 批次发送的条件为：缓冲区数据大小达到 batch.size 或者linger.ms达到上限，哪个先达到就算哪个。 4. 批次

>>阅读原文<<