Kafka的消息发送过程中,需要先创建ProducerRecord对象,并把数据封装到该对象中。然后创建RecordAccumulator消息收集器对象,ProducerRecord对象会调用send方法将消息发送到RecordAccululator对象中暂存。 Sender负责将消息构建成请求,通过I/O网络将消息发送到对应的Kafka Topic中。 KafkaProducer是线程安全的,可以多个线程共享一个KafkaProducer对象。