flink常用依赖包
provided 表示不使用此依赖,如果被注释了表示使用此依赖,没有被注释表示不使用此依赖。本地调试的时候选择注释,打包到服务器上运行时如果服务器上有flink的依赖可以选择不注释,不把依赖打入jar包中。
1. flink-java 依赖包(java代码写kafka)
1 2 3 4 5 6
| <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>${flink.version}</version> <scope>provided</scope> </dependency>
|
2.flink steram 依赖包(java版本)
1 2 3 4 5 6
| <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_${scala.binary.version}</artifactId> <version>${flink.version}</version> <scope>provided</scope> </dependency>
|
3.flink steram 依赖包(scala版本)
1 2 3 4 5 6
| <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-scala_${scala.binary.version}</artifactId> <version>${flink.version}</version> <scope>provided</scope> </dependency>
|
4.flink webUI 依赖包(flink本地测试时使用)
1 2 3 4 5 6
| <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-runtime-web_${scala.binary.version}</artifactId> <version>${flink.version}</version> <scope>provided</scope> </dependency>
|
5.flink 连接依赖包
1 2 3 4 5 6
| <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_${scala.binary.version}</artifactId> <version>${flink.version}</version> <scope>provided</scope> </dependency>
|
6.flink-kafka 连接依赖包
1 2 3 4 5 6 7
| <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka_2.12</artifactId> <version>${flink.version}</version> <scope>provided</scope> </dependency>
|