1、修改生产环境配置

src/main/java/com/censoft/flink/StreamingJob.java

@@ -9,11 +9,13 @@ import com.censoft.flink.transform.AlgorithmBaseFilterFunction;
 import com.censoft.flink.transform.AlgorithmTypeFlatMapFunction;
 import com.censoft.flink.transform.ResultExistFilterFunction;
 import com.censoft.flink.transform.UpdateLiveFilterFunction;
+import org.apache.flink.api.common.serialization.SimpleStringSchema;
 import org.apache.flink.api.java.utils.ParameterTool;
 import org.apache.flink.core.fs.FileSystem;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
+import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer;
 
 import java.lang.reflect.Method;
 import java.util.Arrays;
@@ -75,7 +77,7 @@ 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 打印输出
         outputStreamOperator.print();