java客户端发消息到kafka_java 代码 ,推送消息至kafka

前言

下面记录下如何使用kafka的java客户端向kafka的broker发送消息

1、导入maven依赖

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

2、发送方式1，直接发送

比如我们提前创建好了一个名为 ”zcy222“的topic，测试的数据将发到这个topic中

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
 
import java.util.Properties;
 
public class Producer1 {
 
    public static void main(String[] args) throws Exception {
 
        // 1. 创建 kafka 生产者的配置对象
        Properties properties = new Properties();
        // 2. 给 kafka 配置对象添加配置信息：bootstrap.servers
        properties