温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
那接下来呢,就要写我们flink CDC的一个代码了啊,那这个很简单,我们首先呢,构建我们的项目,好吧,啊,那我们去创建一个项目。呃,这个地方呢,选择就好了,然后下一步。好,那这个地方呢,我们用com.I的硅谷。呃,然后这边呢,我们叫杠。好吧。然后把这个名字做一个替换。好完成,嗯,当前窗口就OK。好,那在这个里边呢,我们不写代码,因为未来除了弗利CDC,我们还有这个实时的任务,还有未来数据接口,对吧,所以有分多个模块,那把这个。为了以防万一出错,我们把这个删掉,然后在这里边呢,我们去创建一个模块。就叫G。Link-CADC,好吧。
01:01
啊,完成完成之后呢,我们导入对应的这个依赖啊,那包结构呢,这个还好,只有两个,一个APP一个U对吧,工具包啊呃,那我们也可以把这个包先去创建好,这个也无所谓,创建两个包,一个YouTube。一个APP就是我们的启动类,我们放在这个APP,呃,然后这里边呢,放一些工具类啊,那接下来呢,把这个文件拿过来。嗯,我就直接整个的拿过来了啊。然后呢,我们把给大家去解释一下,呃,或者说这里边以防万一我们这个名字有一点不一样,对吧,那我从这个build一直拿到这个。啊,上面的这些东西呢,我就不动了,因为有可能写的不一样,对不对,那之前呢,我们写的叫org.example啊,那这次呢,我用的是com点硅谷对吧,这个其实都无所谓,一个包名。好,那这边呢,我们就导进来,导进来之后呢,我们来看一下,哎,这边是少写了一个flink wson它没有读到。
02:08
啊,01:13点一,那没有关系啊,它会去自动下载一下,呃,或者说呢,我们来看一下是不是我们这个地方啊,已经加载完成了,这个我们就稍微等一下,大家也一样啊,有可能我的没有仓库呢,之前是出了一点小小的问题,所以导致呢,这边他会去重新去下载一下啊,那我们稍等一下就好了,好吧。好,那这边呢就OK了,所有的环境都是准备好的,那我们看一下导了哪些东西啊,首先我们fli基本的运营环境,Fli Java fli stream Java对吧?我们来写这个代码,弗Li客户端啊,为了在本地运行方面,但其实我们这个项目呢,在本地运营不了,因为大家还看到了我们远程连接只能连接到主节点对不对?呃,哈客户端因为设及到未来工作的时候,大家可能会需要设置这个point的,然后地址呢,一般我们选用这个HDS啊,所以呢,这边有个哈的客户,呃,然后弗Li买CC的一个连接器啊,那这个我们用到弗Li CC,呃,然后呢,Table API所依赖的,然后跟卡卡的连接啊,那因为我们是要把。
03:12
买的log读取过来,把数据传输到卡夫卡,接下来三个是的配置信息啊,还有一个阿里巴巴的一个啊,方便我们使用。好,那下面呢,是一个打包工具啊OK,这个就是基本的一个依赖,咱们就搞定了这个项目呢,咱们先把它搭起来啊。
我来说两句