温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
好,那接下来我们看一下什么是flink CDC,那弗Li CDC呢是其实是阿里开发的一个组件,可以连接我们的关系型数据库,对于我们数据库当中呢,可以读取全量数据和增量数据的这样的一个sources组件啊呃,那目前呢,它也已经开源了,开源地址呢,我们可以看一下在这个当中,同时这个地址当中呢,给我们也提供了一些文档可以参考啊,我们也可以去查阅,呃,有更多更新的内容呢,官方也会写在这个内容当中啊呃,那这边呢,我们稍微可以等一下,等到这个打开,因为现在可能网速呢稍微有点差。好,这边呢,我们已经打开了这个网页,大家可以来看一下,这个当中呢,也会对于我们。CC相关内容做一些介绍,包括这个地方还有一个文档啊,我们可以详细的看到,呃,那么这里边呢,是有一些关于买S啊,这种数据库的一个要求,以及对于我们link它的一个版本,还有Java jdk,也就是我们所说的JDK它版本的一个要求,同时在这里边给我们提供了一个比较简单的案例,第一个是Li s的方式来实现这个功能,那另外一个呢,是data stream的API的方式也可以读取我们的这个数据啊。
01:29
好,这是它的一个官方介绍,那么其实所谓的CDC呢,我们给大家介绍一下,就是内置了DB这个组件,也就是说它是通过be log这种方式来实现的,也就是说它可以读取,直接读取这个数据。呃,那我还要聊一下,市面上有canal mace以及division,明明人家有了这个CDC的工具了,那为什么还会?出现flink CDC这样的内容,那我们可以想一个很简单的问题,假如说我们要监控MYS当中变化或者新增的数据来做一些业务分析。
02:07
那如果没有fli CC,我们要用的方式,用canal或者说makece division这种方式实时的读取数据,然后将数据传输到我们的消息中间键,之后呢,再用flink程序或者说Spark streaming来消费。我们消息中间件当中的数据再做加工处理,而此时利CDC如果它可以直接读取我们动态变化的数据,那是不是可以读取完数据直接做加工啊?那这个就是可以节省一层消息中间件了,大家想一下是不是这个。OK吧啊,那也就是说弗Li CDC它其实是有它出现的一个道理的啊,OK,这是我们介绍了一下弗Li CDC,只要大家搞清了CDC是什么,那弗Li CDC其实就比较简单了啊,那总结一句话就是说它是内置了B这个组件的一个可以基于并lo方式读取my circle当中增删改数据的。
03:14
一个内容啊,一个source组件。
我来说两句