[Scala/Flink] 读写 Kafka_flink从kafka读取数据scala

1. 依赖&版本

Flink 与 Kafka 的一些方法调用跟其版本有关, 下面是我使用的版本

<properties>
  <maven.compiler.source>8</maven.compiler.source>
  <maven.compiler.target>8</maven.compiler.target>
  <maven.compiler.compilerVersion>8</maven.compiler.compilerVersion>

  <flink.version>1.12.1</flink.version>
  <scala.version>2.12.7</scala.version>
  <kafka.version>2.4.1</kafka.version>
</properties>

<dependencies>
  <dependency>
     <groupId>org.scala-lang</groupId>
     <artifactId>scala-library</artifactId>
     <version>${scala.version}</version>
   </dependency>
   
   <dependency>
      <groupId>org.apache.flink</groupId>
      <artifactId>flink-connector-kafka_2.12</artifactId>
      <version
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20