学习笔记Kafka—— Kafka 开发环境配置及Producer API
Posted 别呀
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了学习笔记Kafka—— Kafka 开发环境配置及Producer API相关的知识,希望对你有一定的参考价值。
一、开发环境说明
1、创建Maven工程
1.1、开发环境
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 实战
发送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();
运行java代码,然后就可以查看了
发送KV消息:
指定Partition
以上是关于学习笔记Kafka—— Kafka 开发环境配置及Producer API的主要内容,如果未能解决你的问题,请参考以下文章
学习笔记Kafka—— Kafka 开发环境配置及Producer API
学习笔记Kafka—— Kafka安装配置—— Kafka多代理配置及常用操作
学习笔记Kafka—— Kafka安装配置—— Kafka多代理配置及常用操作
学习笔记Kafka—— Kafka 与Spark集成 —— 原理介绍与开发环境配置实战