2.如果在Windows使用小皮
在小皮面板里设置,如图:
打开bin日志开关
搭建Flink CDC java环境
添加maven相关pom
在pom里添加相关Flink CDC依赖
<!-- flink connector 基础包-->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-base</artifactId>
<version>1.14.4</version>
</dependency>
<!-- CDC mysql 源-->
<dependency>
<groupId>com.ververica</groupId>
<artifactId>flink-sql-connector-mysql-cdc</artifactId>
<version>2.3.0</version>
</dependency>
<!-- Flink Steam流处理-->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
<version>1.14.4</version>
</dependency>
<!-- flink java客户端-->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients_2.12</artifactId>
<version>1.14.4</version>
</dependency>
<!-- 开启webui支持,默认是8081,默认没有开启-->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_2.12</artifactId>
<version>1.14.4</version>
</dependency>
<!-- Flink Table API和SQL API使得在Flink中进行数据处理变得更加简单和高效
通过使用Table API和SQL API,可以像使用传统的关系型数据库一样,通过编写SQL语句或者使用类似于
Java的API进行数据处理和分析-->
<dependency>
本文转载自: https://blog.csdn.net/2303_79055785/article/details/137757113
版权归原作者 小猪佩琪962 所有, 如有侵权,请联系我们删除。
版权归原作者 小猪佩琪962 所有, 如有侵权,请联系我们删除。