生产者的基本实现

2021-12-10 16:30:16 阅读：148 来源： 互联网

标签：基本生产者 kafka 发送实现 props import Properties metaData

Maven必须配置

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

Java实现

package com.qf.kafka;

import org.apache.kafka.clients.producer.*;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Properties;
import java.util.concurrent.ExecutionException;

public class MyProducer {
    // 定义TOPIC名称
    private final static String TOPIC_NAME = "my-replicated-topic";

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 1.设置参数
        // 使用 Properties对象 存放键值对(参数配置信息)
        Properties props = new Properties();
        // 键值对中存入 bootstrap_server => kafka节点或集群(用逗号隔开)
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.232.136:9092,192.168.232.136:9093,192.168.232.136:9094");
        // 把需要发送的key从字符串序列化为字节数组
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        // 把需要发送的value从字符串序列化为字节数组
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

        // 2.创建生成消息的客户端，传入参数
        KafkaProducer<String, String> producer = new KafkaProducer<String, String>(props);

        // 3.创建消息
        // 未指定发送分区，具体发送的分区计算公式:hash(key)%partitionNum
        // key:决定了往分区上发；value：具体要发送的消息内容
        ProducerRecord<String, String> producerRecord = new ProducerRecord<String, String>(TOPIC_NAME, "mykeyvalue", "hello kafka");

        // 4.发送消息,得到消息发送的元数据并输出
        RecordMetadata metaData = producer.send(producerRecord).get();
        System.out.println("同步方式发送消息结果：" + "topic-" + metaData.topic() + "|partition-" + metaData.partition() + "|offset-" + metaData.offset());
    }
}

标签：基本,生产者,kafka,发送,实现,props,import,Properties,metaData
来源： https://blog.csdn.net/swx7410852963/article/details/121859152

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

生产者的基本实现