Flink读取Kafka数据案例_flink读取kafka中的json数据-CSDN博客

网友收藏2024-01-23 07:23

链接地址：https://blog.csdn.net/weixin_44911081/article/details/123066829
链接标题：Flink读取Kafka数据案例_flink读取kafka中的json数据-CSDN博客
所属网站：blog.csdn.net
被收藏次数：1595

文章浏览阅读2k次。案例准备：1、启动zookeeper2、启动Kafka3、打开IDEA案例需求：需求：使用flink读取Kafka中的数据代码实现：def main(args: Array[String]): Unit = { val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism(1) val props = new Properties() props.put("boo_flink读取kafka中的json数据

本文地址：https://tebull.com/detail/503927.html

标签：flink读取kafka中的json数据