00:00
好的前期准备工作啊,我们已经做完了,接下来呢,我们就来配置一下对应的这个,那我们这个啊,要配置成什么样呢?看这张图。这张图当中告诉我们,我们这个的配置呢,是t Di source对应的memory channel以及卡法S,是这样吗?好,那下面呢,我们创建一个文件夹。来到这里面创建一个目录,先make d啊。Job斯啊,进到这个job布斯里面,这里面存放我们未来的一个配置文件,那这个名字怎么起呢?VM,我们的数据啊,是在file里面,然后to。到哪呢?哎,到这个对应的卡卡。点。com这样一个配软件。那这个配准件我就直接拿过来了,拿过来之后呢,呃,一会儿呢,给大家解释一下这个文件怎么来的啊。那如果这个呢,不太懂的同学呢,可以看一下之前的的相关配置。
01:04
那好,那这个呢,我先保存。保存完毕之后给大家解释一下。首先第一个。那你要配置呢这么几要素,第一个先配置它的主件,比如说定义所有的主件,South China和think。定义完毕之后,你要配置它对应的south,然后还有呢,对应的。最后呢,把这些组件拼接在一起,就这么标准的五步就完事了,好,那我们一步一步来,这一步呢,第一组件这没啥说的,哎,我们呢,这个呢叫AGENT1 agent1agent1,那它对应的source呢是r think是KE1 China是C,好,主件定义完毕之后,那下面我们SS,由于我们选择的是TDRS,那你就查看官网,看看TDRS怎么配置。那把它拿过来。打开官网走进来之后啊,点击左侧这个documentation啊文档,那文档呢有两个,上面呢是用户使用的配置信息,下面呢是开发的时候需要写代码啊用到的哈,那我们用上面这个配置就可以了,点开点开之后CTRLF粘贴。
02:13
粘贴过来之后,我们是TDRS。走。走到这儿之后,这里面有关于泰DRS所有的配置信息,那怎么看啊,这文档看上面这块。这块这个文字加粗的地方,记住是必须配置的项啊,一定要注意啊,这些一个都不能少,少了之后它不能工作,那下面没有加粗的呢,属于可选项,比如说可配置可不配置,你不配置的话,它走的就是默认值。好,那说海哥这个我也不太会配啊,不用担心。下面这。看到这了吗?下面这块给你对应的一个样例了啊,我把它钉出来。听出来之后你会发现,哎,这里面涉及到的所有的配置在这里面都有,好,那这个你看跟我的一个配置怎么比的啊。
03:02
那第一个你首先要指定它对应的一个类型。好,那这个类型的就是tell s就是它。那下面我这个tell d source,它监控的是哪一个目录呢?哎,那我这里面监控的,你看他给你的监控这么一个目录啊,那我这个里面监控的就是这个对应的目录啊。那如果你监控的是多个目录的话,那这里面你可以再来一个F2啊,你看这是F1F1啊,对应的F1这个目录就是这个。因为我只放了一个文件。那行,那我是监控这个,那下面,哎,我这个文件。那下面大家回忆一下,说TDR它支持的是断点续传,那它怎么支持的断点续传呢?它是不是得有一个off outside索引文件,把它持久化到磁盘呢?那这个文件呢,其实就下面它。哎,这个文件呢,是专门用来存储我们对应的off文件的,那这样才能实现对应的断点续传功能啊,那你看这几个配置必配的,一配完事了,那这里面都有对应的参考啊,一个是它,一个是这个。
04:10
到那你看哎,这些配置完毕就完事了啊,而且这些呢,都在这里面对应的必配相声。这些。哎,这么几个啊,那说海哥这里面你那个China还没配呢,说这个China这组件,哎,China在后面的时候啊。按这块给你进行一个配置就可以了啊,不用着急行,那这个呢就配置完毕了,Source,那下面我们来看一下对应的这个channel,那channel我们选择的是memory channel。那怎么配啊,仍然是。把它分过来。慢。走。慢摄头所有相关信息都在这儿了,哎,很好,这里面呢只有一个type需要配置,比如说这是必配项,那这怎么配在这儿呢?这里面都有对应的案例啊,所以说这个flu用起来非常简单啊,拿过来只有它是必备项,其他呢都是可选项。
05:05
那我这里面多配了两个。我给你这两个都配了,其实你不配也行,把它干掉,默认的这两个都是100哈,100就完事。行,那再往下走,下面呢是对应的配置谁啊,配置的对应的是think啊,比如说卡夫卡S,那卡卡辛怎么配啊。套路都一样的。那来到这儿之后,你会发现哦,卡法进呢有这么多参数啊,其中必配项呢有两个,一个呢是它对应的类型,另一个呢,就是你要连接上卡法对应的集群。那老规矩,他下面一定会给你准备对应的案例,你看都在这放着吗?一定出来。定出来之后跟我们的对比一下。首先第一个。哎,我们这里面它对应的类型,哎,你要是它的全类名对吧,它官网已经给你写了啊,必须这么配就行,那下面呢是连接上对应的集群,那就是hi度102103104对应的9092啊连接上还有呢,我这里面写了,哎我这个数据啊要发往到卡发的哪一个主题上,哎,我是发到for主题那指定一个topic啊。
06:10
那下面这三个参数呢,其实你可填可不添,不填的话用它默认值就可以了,那它什么含义啊,再一个呢,是从服当中,哎一批次拉取多少条日志,那一次呢是拉取20条,那另一呢是AC,那AC呢有零,一和负一,那这里配置是一,哎,追求的是效率,还有另格2S默认值是零,那我这里面给它设置一毫秒啊,是这个意思啊,你看就这些值,那下面呢,把这些主件拼接在一起就成了。啊,这就是对应的配置信息,那我们已经复制完了,对吧?哎,复制完之后呢,我们把这个嘛启动起来,好吧,把它请起来。那这个怎么起呢?哎,非常简单,B flu NG,然后呢,A。A,然后杠C,那这里面指定对应的抗复目录,然后杠N,那名字呢是A1啊,这个A的名称是A1,然后之后我们来一个。
07:03
杠F,比如说你修改的配置文件在哪里呢?Jobs里面。哎,就是这个文件啊,那这里面就指定完毕了啊,比如说这个agent呢,这是固定的写法,然后杠C是指定你这个com信息之后呢,杠N,哎是你那个配置文件当中是有那个A1啊啊A帧的名称是A1啊,那杠F呢,是我们刚才写的配置文件,按照这个配置文件进行一个启动。那你要想在后台启动的话,加个尾号啊走。啊,那这样呢,看到这个application之后,你发现这个flu呢,已经正常的启动了,那正常启动之后,下面呢,我们开始进行测试了啊怎么测试,给大家回顾一下整体这个架构图。把它拎出来。现在我们整个环境当中。他已经安装完毕了,他也OK了,这块呢也已经启动了,那下面的话就是需要准备一个文件放到这个目录里面,并往这个文件里面追加数据,然后在这边观察能不能收到数据,是这样的过程吗?好,那现在呢,OG model这个目录我还没有。
08:11
然后这里面,哎,我们make d一下。Log。进到APP log,进到这里面创建一个文件VP.log,就它,然后写一个hello。保存。观察一下这边看能不能收到数据啊,你看哎,这面是不是就收到了一个哈数据啊,哎,然后我再往这里面追加信息,看他能不能收到啊,追加信息怎么追加呢,一口。Hello。走。好,我又追加了一条哈,你看这边也能够收到对应的哈信息,那就说明整个这个通道呢是正确的啊行,那这个案例呢,我们就测试完毕了哈。
我来说两句