kafka flink.7z

放入数据到kafka, flink读取kafka数据到mysql SingleOutputStreamOperator student = env.addSource(new FlinkKafkaConsumer010( "student", new SimpleStringSchema(), props)).setParallelism(1) .map(string -> JSON.parseObject(string, Stud