flink开发中整合flinksql、kafka、mysql、hbase等问题与结果记录

在flink开发中，通常会配合flinksql、kafka、mysql、hbase等一块使用，为避免jar包缺失、冲突，现整理一下。

一、版本说明

flink：1.13.0
kafka：2.11
mysql：8.0
hbase：2.2.3

二、flink+socket

1）socket使用nc命令实现

nc -lk 9000

2）只需要flink-1.13.0解压后的原始的10个jar，不需要其它jar，如下：

二、flink/flinksql+kafka所需jar

flink-connector-kafka_2.11-1.13.0.jar
kafka-clients-2.1.1.jar

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kafka_2.11</artifactId>
    <version>1.13.0</version>
</dependency>
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.1.1</version>
</dependency> 

三、flinksql+mysql所需jar

flink-connector-jdbc_2.11-1.13.0.jar
mysql-connector-java-8.0.11.jar

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-jdbc_2.11</artifactId>
    <version>1.13.0</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.11</version>
</dependency>