Flink入门，flink接入kafka数据源，消费数据并处理数据
<properties>
<>UTF-8</>
<>1.19.0</>
<>1.8</>
<>2.12</>
<>${}</>
<>${}</>
<>2.17.1</>
</properties>
<repositories>
<repository>
<id></id>
<name>Apache Development Snapshot Repository</name>
<url>/content/repositories/snapshots/</url>
<releases>
<enabled>false</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
</repositories>
<dependencies>
<!-- Apache Flink依赖项 -->
<!-- 之所以提供这些依赖项，是因为它们不应该打包到JAR文件中. -->
<dependency>
<!--Table API + DataStream-->
<groupId></groupId>
<artifactId>flink-table-api-java-bridge</artifactId>
<version>${}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId></groupId>
<artifactId>flink-clients</artifactId>
<version>${}</version>
<scope>provided</scope>
</dependency>
<!--JDBC连接器-->
<dependency>
<groupId></groupId>
<artifactId>flink-connector-jdbc</artifactId>
<version>1.16.0</version>
</dependency>
<!-- 在这里添加连接器依赖项。它们必须在默认作用域(编译)中。 -->
<dependency>
<!--kafka连接器-->
<groupId></groupId>
<artifactId>flink-connector-kafka</artifactId>
<version>1.16.0</version>
</dependency>
<!-- 添加日志框架，以便在IDE中运行时生成控制台输出. -->
<!-- 默认情况下，这些依赖项从应用程序JAR中排除. -->
<dependency>
<groupId>.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId>
<version>${}</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>${}</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>${}</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId></groupId>
<artifactId>lombok</artifactId>
<version>1.18.30</version>
<scope>compile</scope>
</dependency>
</dependencies>