1. 首页
  2. 编程语言
  3. Java
  4. kafka flink.7z

kafka flink.7z

上传者: 2020-08-11 03:31:33上传 7Z文件 1.82KB 热度 20次
放入数据到kafka, flink读取kafka数据到mysql SingleOutputStreamOperator student = env.addSource(new FlinkKafkaConsumer010( "student", new SimpleStringSchema(), props)).setParallelism(1) .map(string -> JSON.parseObject(string, Stud
用户评论