《Flink 使用 JDBCAppendTableSink 操做 Mysql入门示例》 Java版

前面写了个Flink操做Mysql的示例,Scala版本的,不过是对照源码的翻译。这两天使用Java开发(boss说不要用scala),这里贴一下使用方法。超简单的,你们注意看下代码。java mysql相关的依赖(kafka的自行添加)mysql <dependency> <groupId>org.apache.flink</groupId> <a
相关文章
相关标签/搜索