From 24f1855cadd4e08cbd6237dff0dc39b41424c351 Mon Sep 17 00:00:00 2001
From: zangkun <t04041143@163.com>
Date: Fri, 24 Jun 2022 15:29:53 +0800
Subject: [PATCH] =?UTF-8?q?Revert=20"=E5=A4=87=E4=BB=BD"?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

This reverts commit bbadd8bab6c27efa18dc3a55304114ada93016fa.

# Conflicts:
#	src/main/java/com/qniao/iot/rc/KafkaMessage.java
#	src/main/java/com/qniao/iot/rc/KafkaMessageSchema.java
#	src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java
---
 .gitignore                                                | 1 +
 pom.xml                                                   | 8 ++++----
 .../com/qniao/iot/rc/RootCloudIotDataFormatterJob.java    | 2 +-
 3 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/.gitignore b/.gitignore
index e689473..9a21903 100644
--- a/.gitignore
+++ b/.gitignore
@@ -7,6 +7,7 @@
 # ---> Java
 # Compiled class file
 *.class
+target/
 
 # Log file
 *.log
diff --git a/pom.xml b/pom.xml
index 34215dd..bf19bae 100644
--- a/pom.xml
+++ b/pom.xml
@@ -29,7 +29,7 @@ under the License.
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <flink.version>1.14.5</flink.version>
+        <flink.version>1.15.0</flink.version>
         <target.java.version>1.8</target.java.version>
         <maven.compiler.source>${target.java.version}</maven.compiler.source>
         <maven.compiler.target>${target.java.version}</maven.compiler.target>
@@ -41,19 +41,19 @@ under the License.
         <!-- These dependencies are provided, because they should not be packaged into the JAR file. -->
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-streaming-java_2.12</artifactId>
+            <artifactId>flink-streaming-java</artifactId>
             <version>${flink.version}</version>
         </dependency>
 
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-clients_2.12</artifactId>
+            <artifactId>flink-clients</artifactId>
             <version>${flink.version}</version>
         </dependency>
 
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-connector-kafka_2.12</artifactId>
+            <artifactId>flink-connector-kafka</artifactId>
             <version>${flink.version}</version>
         </dependency>
 
diff --git a/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java b/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java
index 7d5c90e..fe14ba8 100644
--- a/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java
+++ b/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java
@@ -36,7 +36,7 @@ public class RootCloudIotDataFormatterJob {
         final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
 
         KafkaSource<KafkaMessage> source = KafkaSource.<KafkaMessage>builder()
-                .setBootstrapServers("localhost:9092")
+                .setBootstrapServers("kafka:9092")
                 .setTopics("test_topic")
                 .setGroupId("flink-kafka-demo")
                 .setStartingOffsets(OffsetsInitializer.latest())