Flink 读取 Kafka 消息并批量写入到 MySQL实例

前言说明 环境搭建可参考 《kafka+flink集成实例》 本实例主要实现功能以下: 模拟消息生成->Kafka->Flink->Mysql 其中Flink作数据流收集并定时批量写入到Mysql 在某些应用场景里面可能会用到java 环境依赖 本例使用Intellij IDEA做为项目开发的IDE。 首先建立Maven project,group为’com.zuoan’,artifact id为
相关文章
相关标签/搜索