Kafka源码阅读系列——Producer

Producer

Kafka源码的exmaple模块有一个Producer类,继承了Thread类,构造方法会指定topic,是否异步,是否幂等,配置Kafka集群信息,初始化一个KafkaProducer主线程,它会分别初始化一个拦截器,kv序列化器,分区选择器(均匀分配消息到不同分区,也可以使用自定义分区器指定),消息累加器RecordAccumulator(缓冲区)以及一个Sender子线程。Producer是一个线程,所以run方法里面,KafkaProducer将消息封装为ProducerRecord然后调用send方法带着指定的topic发送。

Kafka源码阅读系列——Producer

上一篇:我的单点登录


下一篇:react学习-受控组件与非受控组件