1、修改生产环境配置

d492d11f · 周昊 · 07c31e19 · d492d11f
Commit d492d11f authored Sep 15, 2023 by 周昊
Hide whitespace changes
Inline Side-by-side

Showing with 0 additions and 1 deletion

src/main/java/com/censoft/flink/StreamingJob.java src/main/java/com/censoft/flink/StreamingJob.java +0 -1

No files found.
--- a/src/main/java/com/censoft/flink/StreamingJob.java
+++ b/src/main/java/com/censoft/flink/StreamingJob.java
@@ -97,7 +97,6 @@ public class StreamingJob {
        });

        //3、5 输出kafka
-        outputStreamOperator.addSink(new FlinkKafkaProducer("192.168.10.137:9092", "test-topic", new SimpleStringSchema()));
        outputStreamOperator.addSink(new FlinkKafkaProducer("172.16.33.152:9092", "test-topic", new SimpleStringSchema()));

        //3、6 打印输出