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发数据的主要内容,如果未能解决你的问题,请参考以下文章
Debezium系列之:联合主键数据发往kafka topic相同分区
kafka通过控制台模拟消息发送和消息接收正常,但是通过javaAPI操作生产者发送消息不成功 消费者接收不到数据解决方案?