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. UTF-8 - 1.14.5 + 1.15.0 1.8 ${target.java.version} ${target.java.version} @@ -41,19 +41,19 @@ under the License. org.apache.flink - flink-streaming-java_2.12 + flink-streaming-java ${flink.version} org.apache.flink - flink-clients_2.12 + flink-clients ${flink.version} org.apache.flink - flink-connector-kafka_2.12 + flink-connector-kafka ${flink.version} 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 source = KafkaSource.builder() - .setBootstrapServers("localhost:9092") + .setBootstrapServers("kafka:9092") .setTopics("test_topic") .setGroupId("flink-kafka-demo") .setStartingOffsets(OffsetsInitializer.latest())