Java kafka发数据

Posted cleaver

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java kafka发数据相关的知识,希望对你有一定的参考价值。

kafka 均匀发数据函数:

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;

import java.io.Serializable;
import java.util.List;
import java.util.Properties;
public class KafkaSendUtil implements Serializable{
    public static void sendMsg(String brokerList,String topic,List<String> datas){
        Properties properties = new Properties();
        properties.put("bootstrap.servers",brokerList);
        properties.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
        properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");
        KafkaProducer producer = null;
        try{
            producer = new KafkaProducer(properties);
            for(int i=0;i<datas.size();i++){
                ProducerRecord<String,String> message = new ProducerRecord<String, String>(topic,datas.get(i));
                producer.send(message);
            }
        }catch(Exception ex){
            ex.printStackTrace();
        }finally{
            if(producer != null){
                producer.close();
            }
        }
    }
}

 

以上是关于Java kafka发数据的主要内容,如果未能解决你的问题,请参考以下文章

Kafka--05---java客户端代码实现

如何用Java向kafka发送json数据

Kafka-文件管理

Debezium系列之:联合主键数据发往kafka topic相同分区

kafka介绍

kafka通过控制台模拟消息发送和消息接收正常,但是通过javaAPI操作生产者发送消息不成功 消费者接收不到数据解决方案?