学习笔记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集成 —— 原理介绍与开发环境配置实战

学习笔记Kafka—— Kafka 与Spark集成 —— 原理介绍与开发环境配置实战

学习笔记Kafka—— Kafka 与Spark集成 —— 原理介绍与开发环境配置实战