kafka客户端流程分析 发表于 2020-05-19 更新于 2020-10-09 分类于 kafka 阅读次数： Valine： 生产者初始化 发送消息 拉取元数据 sender线程拉取，主线程等待(使用version和上一次版本号进行比较，来等待sender线程唤醒或者时间超时) RecordAccumulator缓存区有一个对象batches，存在多个队列，每个队列代表一个分区 sender线程NetWorkClient Selector KafkaChannel NIOkafka发消息只会发送到leader partition