flink1.20.2环境部署和实验-2
flink1.20.2环境部署和实验-2
- 1.实验
-
- 1.1.maven统一配置(非必须)
- 1.2.创建java工程
-
- 1.2.1.创建
- 1.2.2.pom.xml的内容
- 1.3.运行测试
续flink1.20.2环境部署和实验-1的内容,搭建flink应用开发环境,实现flink消费kafka数据,并打印在控制台。
1.实验
1.1.maven统一配置(非必须)
若需要,先做下IDE中maven的统一配置
打开idea

搜索maven,修改成本地自行安装的某个maven目录,这里使用的是maven3.9.11版本。


1.2.创建java工程
1.2.1.创建
这里采用maven工程模板,其中:
- JDK 11
- Catalog使用maven centeral,
- Archetype使用org.apache.flink:flink-quichstart-java
- Version1.20.2

1.2.2.pom.xml的内容
<dependencies><!-- Apache Flink dependencies --><!-- These dependencies are provided, because they should not be packaged into the JAR file. --><dependency><groupId>org.apache.flink</groupId><artifactId>flink-core</artifactId><version>${flink.version}</version><scope>provided</scope></dependency><dependency><groupId>org.apache.flink</groupId><artifactId>flink-streaming-java</artifactId><version>${flink.version}</version><scope>provided</scope></dependency><dependency><groupId>org