大数据_Flink_Java版_数据处理_流处理API_Sink操作_把数据利用JDBC存储到Mysql等关系型数据库---Flink工作笔记0041

然后我们再来看,如何把数据从flink中,读取,然后同步到MySql数据库中.

注意这里我们首先需要一个mysql的连接器对吧,但是,很遗憾,在1.10版本的flink中,并没有

提供,mysql的 连接器,我们说的那个bahir也没有提供mysql的连接器,那么这个时候

我们就必须只能,自己去自定义一个Mysql的连接器了对吧.去自定义一个Sink.

我们去做一下.首先引入依赖.

然后,去新建一个类SinkTest4_jbdc