1、修改日志输出

d34f7282 · 周昊 · b993bcba · d34f7282
Commit d34f7282 authored Sep 14, 2023 by 周昊
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

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

No files found.
--- a/src/main/java/com/censoft/flink/StreamingJob.java
+++ b/src/main/java/com/censoft/flink/StreamingJob.java
@@ -74,7 +74,7 @@ public class StreamingJob {
        SingleOutputStreamOperator<String> outputStreamOperator = streamOperator.map(AlgorithmPushDto::toString);

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

        //3、6 打印输出
        outputStreamOperator.print();