一、開發(fā)環(huán)境說明

1、創(chuàng)建Maven工程

1.1、開發(fā)環(huán)境

Maven && JDK

---

1.2、Pom配置

Compiler Configuration

在pom.xml添加：

<properties><maven.compiler.target>1.8</maven.compiler.target><maven.compiler.source>1.8</maven.compiler.source> </properties> <dependencies><dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.3.1</version></dependency> </dependencies> <build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.6.1</version><configuration><source>1.8</source><target>1.8</target></configuration></plugin></plugins> </build>

然后IDEA就會自動幫我們添加依賴

二、Kafka Producer API

2.1、Producer & KafkaProducer class

2.2、KafkaProducer class

2.3、ProducerRecord class

2.4、KafkaProducer 實(shí)戰(zhàn)

發(fā)送V消息

package demo01;import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.common.protocol.types.Field;import java.util.HashMap; import java.util.Map;public class SimpleProducer {public static void main(String[] args){String topic = "test_02_02";Map<String,Object> kafkaProperties = new HashMap<>();kafkaProperties.put("bootstrap.servers", "node100:9092,node101:9092,node102:9092");kafkaProperties.put("acks", "all");kafkaProperties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");kafkaProperties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");Producer<String, String> producer = new KafkaProducer<>(kafkaProperties);for (int i = 0; i < 100; i++)producer.send(new ProducerRecord<>(topic, Integer.toString(i)));producer.close();} }

運(yùn)行java代碼，然后就可以查看了

發(fā)送KV消息：

指定Partition

總結(jié)

以上是生活随笔為你收集整理的学习笔记Kafka（五）—— Kafka 开发环境配置及Producer API的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。