java 读取文件内容写入kafka

た入场券 2022-11-18 04:54 331阅读 0赞

package Project;
    
    import org.apache.kafka.clients.producer.KafkaProducer;
    import org.apache.kafka.clients.producer.ProducerRecord;
    
    import java.io.BufferedReader;
    import java.io.FileReader;
    import java.util.Properties;
    
    public class KafkaProducerDemo {
        public static void main(String[] args) throws Exception{
            writeToKafka("test");
        }
    
        //包装一个写入kafka的方法
        public static void writeToKafka(String topic) throws Exception{
            //kafka配置
            Properties properties = new Properties();
            properties.setProperty("bootstrap.servers", "localhost:9092");
            properties.setProperty("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
            properties.setProperty("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    
            //定义Kafka Producer
            KafkaProducer<String, String> kafkaProducer = new KafkaProducer<>(properties);
            //用缓冲方式读取文本
            BufferedReader bufferedReader = new BufferedReader(new FileReader("filePath"));
            String line;
            while((line = bufferedReader.readLine())!=null){
                ProducerRecord<String, String> producerRecord = new ProducerRecord<>(topic, line);
                //发送数据
                kafkaProducer.send(producerRecord);
            }
            kafkaProducer.close();
        }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，331人围观）

还没有评论，来说两句吧...

相关阅读

相关【scala】scala写入文件，读取文件内容

package com.xrx import java.io.{ File, FileReader, PrintWriter, R...

╰+攻爆jí腚メ/ 2024年04月17日 11:27/ 0 赞/ 74 阅读

相关 java 读取文件内容写入kafka

package Project; import org.apache.kafka.clients.producer.KafkaProducer;

た入场券/ 2022年11月18日 04:54/ 0 赞/ 332 阅读

相关 Java读取文件内容和写入内容到文件

Java读取文件内容方法和写入内容到文件方法 / One.txt中的数据如下: 1 2 3 4

雨点打透心脏的1/2处/ 2022年06月07日 04:06/ 0 赞/ 373 阅读

相关 Java之创建目录、文件并写入、读取文件内容

1.mkdirs()：可以建立多级文件夹， mkdir()只会建立一级的文件夹。 2.getParentFile()：获得父目录。 3.file.getParentFi

叁歲伎倆/ 2022年05月11日 02:58/ 0 赞/ 821 阅读

相关 scala如何读取和写入文件内容？

\[color=black\]\[size=large\]直接看如下代码：\[/size\]\[/color\] package file i

痛定思痛。/ 2022年04月12日 09:59/ 0 赞/ 282 阅读

相关 java_IO——向文件中写入和读取内容

使用java中OutStream()向文件中写入内容 package Stream; import java.io.File; import

心已赠人/ 2022年03月02日 16:26/ 0 赞/ 276 阅读

相关 java使用字符流写入和读取文件内容

首先了解一下什么是字符流和字节流字节流：操作的是byte类型的数据，以byte为准，主要有两大抽象类OutputStream 和InputStream，使用这两个

亦凉/ 2022年03月01日 02:52/ 0 赞/ 339 阅读

相关 JAVA 创建TXT文件，写入文件内容，读取文件内容

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] package com.abin.facade.ws.m

爱被打了一巴掌/ 2022年01月14日 11:41/ 0 赞/ 567 阅读

相关 Java NIO 读取文件、写入文件、读取写入混合

前言 Java NIO(new/inputstream outputstream)使用通道、缓冲来操作流，所以要深刻理解这些概念，尤其是，缓冲中的数据结构（当前位置(posi

朴灿烈づ我的快乐病毒、/ 2021年10月29日 07:08/ 0 赞/ 542 阅读

相关 Java NIO 读取文件、写入文件、读取写入混合

前言 [Java ][Java]NIO(new/inputstream outputstream)使用通道、缓冲来操作流，所以要深刻理解这些概念，尤其是，缓冲中的[数据结构]

一时失言乱红尘/ 2021年09月14日 02:30/ 0 赞/ 991 阅读