kafka-flink.7z

【文件属性】：

文件名称：kafka-flink.7z

文件大小：2KB

文件格式：7Z

更新时间：2023-03-17 09:07:45

kafka flink

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

【文件预览】：
kafka
----KafkaUtils2.java(1KB)
----ConsumerMain.java(1KB)
----SinkToMySQL.java(2KB)
----Student.java(366B)