Revert "备份"

This reverts commit bbadd8bab6.

# 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

@@ -7,6 +7,7 @@
 # ---> Java
 # Compiled class file
 *.class
+target/
 
 # Log file
 *.log

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>
 

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())