flink开发流程一 自定义source1 定义实体bean2 获取kafka里的数据3 生成流，并对gson转换问题：对类的定义 以及类转换获取kafka的步骤，在测试阶段如何去自定义消费断点时间代码：//1.1case class SpeedBean(rts: Long, parserData: Long, carModelId: String, receiveDate: Long, tripId: String, sn: String, sp: Int, ts: Long,
flink
2023-10-08
42 点赞
0 评论
63 浏览
