Kafka系列2：深入理解Kafka生产者( 三 )_Kafka系列2：深入理解Kafka消费者上篇

项目依赖

以maven项目为例，要使用Kafka客户端，需要引入kafka-clients依赖：

<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>2.2.0</version>
</dependency>

样例

一个简单的创建Kafka生产者的代码样例如下：

Properties props = new Properties();
props.put(\"bootstrap.servers\" \"producer1:9092\");
props.put(\"key.serializer\" \"org.apache.kafka.common.serialization.StringSerializer\");
props.put(\"value.serializer\" \"org.apache.kafka.common.serialization.StringSerializer\");
/*创建生产者*/
Producer<String String> producer = new KafkaProducer<>(props);

for (int i = 0; i < 10; i++) {