大数据_Flink_数据处理_流处理API_Source_从kafka读取数据---Flink工作笔记0027

青青子衿谈育儿

 关注

阅读 50

2022-03-11

然后我们再继续看,flink如果直接从kafka这样的消息队列中读取数据怎么做呢?

 

我们新建一个SourceTest2_Kafka来看,可以看到上面的类

 

然后我们要去,让flink接收kafka的数据的话,

那么首先要能连接kafka,这个时候需要一个依赖

 0.11kafka版本,2.12是scala版本

相关推荐

大数据_Flink_数据处理_流处理API_Source_从文件读取数据---Flink工作笔记0026

吃面多放酱 74 0 0

大数据_Flink_数据处理_流处理API_Source_从集合读取数据---Flink工作笔记0025

guanguans 47 0 0

大数据_Flink_数据处理_流处理API_Source_自定义测试数据源---Flink工作笔记0028

做个橙梦 68 0 0

大数据_Flink_数据处理_流处理API_创建执行环境---Flink工作笔记0024

沈芏 51 0 0

大数据_Flink_数据处理_案例WorldCount_流处理版---Flink工作笔记0009

新鲜小饼干 78 0 0

大数据_Flink_数据处理_流式数据源测试---Flink工作笔记0010

村里搬砖的月野兔 47 0 0

大数据_Flink_数据处理_Flink安装和测试_集群搭建---Flink工作笔记0011

自由的美人鱼 102 0 0

大数据_Flink_Java版_数据处理_流处理API_Sink操作_Kafka---Flink工作笔记0038

惠特曼 60 0 0

大数据_Flink_数据处理_Job的提交运行流程---Flink工作笔记0012

zidea 53 0 0

大数据_Flink_Java版_数据处理_流处理API_Flink支持的数据类型---Flink工作笔记0035

扒皮狼 42 0 0

精彩评论（0）

0 0 举报