Kafkaproducer如何使用-创新互联

Kafka producer如何使用？针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

成都创新互联公司专注于邻水企业网站建设,成都响应式网站建设公司,商城网站定制开发。邻水网站建设公司,为邻水等地区提供建站服务。全流程按需搭建网站，专业设计，全程项目跟踪，成都创新互联公司专业和态度为您提供的服务

一、producer工作流程

producer使用用户启动producer的线程，将待发送的消息封装到一个ProducerRecord类实例，然后将其序列化之后发送给partitioner，再由后者确定目标分区后一同发送到位于producer程序中的一块内存缓冲区中。而producer的另外一个线程（Sender线程）则负责实时从该缓冲区中提取出准备就绪的消息封装进一个批次(batch)，统一发送给对应的broker，具体流程如下图：

二、producer示例程序开发

首先引入kafka相关依赖，在pom.xml文件中加入如下依赖:

<!--kafka-->
  <dependency>
   <groupId>org.apache.kafka</groupId>
   <artifactId>kafka_2.12</artifactId>
   <version>2.2.0</version>
  </dependency>