一、基于前面kafka部署
大数据-玩转数据-Kafka安装文章来源：https://www.toymoban.com/news/detail-634268.html
二、FLINK中编写代码
package com.lyh.flink04;
import org.apache.flink.api.common.serialization.SimpleStringSchema;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer;
import java.util.Properties;
public class flink04_fromkafka {
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(1);
Properties properties = new Properties();
properties.setProperty("bootstrap.servers","hadoop100:9092");
properties.setProperty("group.id","test");
env.addSource(new FlinkKafkaConsumer<>("wordsendertest",new SimpleStringSchema(),properties))
.print();
env.execute();
}
}
三、运行测试
运行本段代码，等待kafka产生数据进行消费。文章来源地址https://www.toymoban.com/news/detail-634268.html
到了这里，关于大数据-玩转数据-FLINK-从kafka消费数据的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
![流批一体计算引擎-4-[Flink]消费kafka实时数据](https://imgs.yssmx.com/Uploads/2024/02/455176-1.png)
