如何编写Kafka生产者端代码实例？

本文共计2322个文字，预计阅读时间需要10分钟。

一、producer工作流程

1.producer用户启动producer线程

2.将待发送的消息封装成ProducerRecord实例

3.对消息进行序列化

4.将序列化后的消息发送给partitioner

5.partitioner确定目标分区

6.将消息发送到目标分区

一、producer工作流程

　　producer使用用户启动producer的线程，将待发送的消息封装到一个ProducerRecord类实例，然后将其序列化之后发送给partitioner，再由后者确定目标分区后一同发送到位于producer程序中的一块内存缓冲区中。