Kafka精进系列005 Kafka生产者流程客户端消息发送过程解析

从前文所述的前两节博客内容中可以看出，在此之前我们已经展示了如何在Docker环境中配置Kafka集群，并且实现了Kafka消息的发送与接收过程。

本文旨在全面探讨Kafka Producer的消息发布机制，并从源码层面解析Kafka的发送过程（版本1.0.0）。

一、KafkaProducer介绍

1、KafkaProducer介绍与使用

KafkaProducer是一个用于接收数据并将其发送到Kafka集群的客户端服务端程序、数据包生成器。
该系统采用单个实例处理以避免多线程并发问题，并且单个线程直接使用一个实例更为高效。

使用示例：

    Properties props = new Properties();
    props.put("bootstrap.servers", "localhost:9092");
    props.put("acks", "all");
    props.put("retries", 0);
    props.put("batch.size", 16384);
    props.