KafkaProducer #send() 方法将消息发送至Broker集群。

Kafka版本3.0，从源码层面对KafkaProducer初始化流程进行分析。

为了实现内存的高效利用，基本上每个成熟的框架或者工具都有一套内存管理机制，kafka的生产者使用BufferPool来实现内存(ByteBuffer)的复用。

反射将创建ServerSocketChannel，channel初始化

检查SPARK_HOME执行环境 执行load-spark-env.sh文件，加载一些默认的环境变量（包括加载spark-env.sh文件） 检查JAVA_HOME执行环境 寻找Spark相关的jar包 执行org.apache.spark.launcher.Main解析参数，构建CMD命令 CMD命令判断 执行org.apache.spark.deploy.SparkSubmit这个类。