增加fast

realtime/hologram-streaming/src/main/java/com/zhht/irn/job/GreenRadioJob.java

@@ -6,9 +6,11 @@ import com.zhht.irn.entity.Stage;
 import com.zhht.irn.sink.GreenRadioSink;
 import com.zhht.irn.utils.FlinkUtils;
 import org.apache.flink.api.common.functions.MapFunction;
+import org.apache.flink.api.java.utils.ParameterTool;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 
+import java.net.URL;
 import java.util.List;
 
 /**
@@ -21,8 +23,10 @@ import java.util.List;
 public class GreenRadioJob {
     public static void main(String[] args) throws Exception {
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
-
-        FlinkUtils.createKafkaStream(args, env)
+        ParameterTool kafkaTool = ParameterTool.fromArgs(args);
+        String topic = kafkaTool.get("kafka.input.topics");
+        System.out.println("***topic:"+topic);
+        FlinkUtils.createKafkaStream(args, env,topic,"GreenRadioJob")
             .map(record -> {
                 // 字符串解析为实体类
                 Cycle cycle = JSON.parseObject(record, Cycle.class);