学习笔记Kafka（五）—— Kafka 开发环境配置及Producer API

1、创建Maven工程

Maven && JDK

Compiler Configuration

在pom.xml添加：

        1.8
        1.8


    
        org.apache.kafka
        kafka-clients
        2.3.1
    


    
        
            org.apache.maven.plugins
            maven-compiler-plugin
            3.6.1
            
                1.8
                1.8
            
        
    

然后IDEA就会自动帮我们添加依赖

发送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 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 producer = new KafkaProducer<>(kafkaProperties);
        for (int i = 0; i < 100; i++)
            producer.send(new ProducerRecord<>(topic, Integer.toString(i)));
        producer.close();
    }
}

运行java代码，然后就可以查看了

发送KV消息：

指定Partition