Kafka生产者之Sender分析

基于kafka2.x 版本 生产者局部架构图   Sender线程run()步骤:场景驱动方式cluster中已有元数据 1、获取元数据 2、判断哪些partitinon有消息要发送,获取分区号对应的broker主机 3、标志还没有拉取到元数据的topic 4、检查与要发送数据的主机网络是否建立好 5、有可能要发送的parttition有多个,有一些parttition的leader partit
相关文章
相关标签/搜索