00:00
来看淘卡,首先我们先嗯,快速的把卡夫卡这个集群先给它装上啊来,那我们双击。嗯,还是按照文档来吧,啊,咱们首先把安装包解压分发,然后配置文件啊修改就行了啊啊进到OPT啊software卡不卡啊,这就是咱们卡夫卡的安装包,那卡夫卡安装包呢,我们看一下这个版本啊,大版本对吧,一个2.1,一个2.4.1,这俩东西应该大家能分清啊前面这个指的是啥?只是开发卡夫卡这个服务端,它语言的版本号对不对,他用什么开发的呀,Skyla语言,Skyla语言咱们学完这个采集项目之后,马上就要学习这个呃skyla了啊,马上学习啊,到时候大家会能够领略到这个SKY的魅力啊,然后其实SKY到时候你会有这样的一种效果啊,就是说呃,如果你学的好,你怎么写这个代码,嗯,都对,你要学的不好嘛,怎么写都报错,就那种啊来,那咱们接下来往下走,下边呢,有一个这个2.4.1,这个是卡夫卡它自己的版本啊,自己版本行,那下来我们给他解压帕杠ZXVF卡夫卡,然后呢杠大C到OT Mo掉。
01:10
好,那我们进到OBT啊,这个猫掉啊,这个给它改名字吧啊卡不卡咱们就只留一卡不卡就行啊。啊,然后进到卡夫卡,呃,卡夫卡里边咱们需要修改的配置文件应该是在这个con当中对吧?啊con啊,那需要修改的文件主要是谁?其实主要就是这个server,点这个properties对不对?那咱们vim,然后server.properties啊,那这里边需要修改的东西都有啥,咱们得看着文档去改了啊来啊,那首先这个标红的都诶文档咱们丢了一步对吧?文档说让我们去创建一个呃,Logs这样的一个文件夹对不对?呃,其实这个文件夹咱们不建也行啊,咱们不创建也行,它运行的过程当中发现没有,它会自己创建出来的啊那说这个你建不加都行啊,没事啊,接下来我们直接进入到下一步,就是修改配置文件,配置文件呢,咱们修改的是这个没问题,咱们已经打开了啊,看看它需要我们改的东西都有谁啊,首先第一个ID,呃不ID呢,它这个其实就无所谓了,没有什么要求,比如说是一到二五没有这种要求啊,你就随便配就行,只要保证啊三台节点或者是几台节点之间是不同的就行,那咱们这个就按照之前的规划,就是零一二百。
02:19
啊,咱就012啊好,那在下一个。啊,删除topic的这个功能啊,这个是什么啊,是这样的,就是卡卡当中,我们这个数据是一个topic的形式去存储的,对吧?啊那呃,我们topic呢,可以创建可以删除啊,可以删除,那正常情况下,呃,如果这个它默认是false啊,如果是false的情况下,你删除这个topic呢,实际上它那个底层数据不会真正的删除啊,它只是加一个删除的标记啊,那如果说我们要真想删,那就得给这个设成处才能删啊,那咱们给它设成处啊,啊那下一个。下一个呢,是指的是卡夫卡日志存放的这个路径。啊,咱们这叫什么叫做OPT,诶这个Mo卡夫卡data对吧,然后大家要知道啊。
03:05
这个它虽然也叫日志存放路径,而且这边呢,也叫logs DR对不对,但它这个日志指的是什么日志啊,是我们什么那个log分街打印的一些日志吗?不是啊,这个要区分开啊,这指的就是咱们生产者发过来的数据啊,这个因为它底层是不是也是以日志文件的形式存在啊,因为它它全是追加,全是追加呢,所以说他就管它叫日志啊,那所以这个只是咱的数据啊,那这个路径它这写的是啥?是呃,Date路径对吧?啊,那OK,那咱们就用这个date路径就行啊,然后最后一个是跟ZK的一个呃,集群连接地址,那这个呢,我们大家也要搞清楚,然后这会儿我们要看一下啊。咱这有一个啥目的,有一个这个。啊,还多102啊,这个268110328104,这个都能看懂对吧,然后在它的后边又加了一个什么,又加了一个卡夫卡,这个卡夫卡指的是什么呀。只是组ker上面的一个根节点,对吧?啊,如果说你不加这个,不加这个,那这个相当于是直接就在组kper那个根节点下边去创建咱们这个路径了啊对不对,那你卡不卡里边它卡不卡启动之后是不是会在主K上注册很多的节点呀,对不对,那这样一来你打开主开的客户端呢,你会发现有一大堆东西啊对,显得比较乱啊,也得比较乱啊,那加上它之后呢,那是不是就相当于我卡不卡所有的节点都在这个路径下边了呀,就看着比较整洁了啊,比较整洁了就是这个作用啊,当然你这个后边这个卡不卡,这你加不加都行啊,加不加都行啊啊那我们按照这个要求,咱们去改一下啊,先加上这个参数来CTRLC啊来我们比如说就在这加吧,啊crl I啊给它加上,然后下边呢,还有其他参数,呃,这个存放这个咱们数据的路径啊,这CTRLC啊拿过来。
04:49
存放数据的路径往下找,咱们搜一下吧。Lock。Log点就这个啊,摁一圈哎啊把这个删掉删掉来放上我们自己的路径好搞定,那接下来再往下走,呃,再往下咱们是需要再加上一个什么来着,加上一个跟组kper这个连接的地址是吧,反正把这个卡普卡也加上。
05:14
来,我们搜一下这个gokeep,好,那把这个改一下。哎。啊。行嗯,搞定行,那这玩意之后我们按shift的这这保存,呃,那卡不卡里边啊,咱们所有的配置文件相当于就这个结束了,呃,然后文档上这边说还有一不让我们配这个环境变量对吧?这个环境变量其实自愿愿意配就配,不愿意配就不用配了啊这个配了之后,只不过就是你启动卡不卡什么的方便一点对吧?啊这个无所谓,咱们就不配这个环金面料了啊,我们直接把这个呃卡不卡分散货比model啊,然后这个卡不卡啊,然后走你。呃,分完之后记得去103104上边呢,去改一下咱们这个,呃环境量,呃对对那个broke ID对吧?啊这个open卡不卡啊,肯这个vm sorry,点这个改成ID。
06:10
1SHIFT CC那这边呢,我们改成C点点C卡夫卡,哎,Conve啊VM啊,这个S拿走这个改成二。Shift对,行了,那改完了,呃,到现在我们相当于卡夫卡整个这个该配的东西都配完了是吧,那接下来我们就呃给它进行启动,那同理卡夫卡还是没有这个群拟脚本的,它还是没有群脚本啊,那没有群脚本的话,那我们就得自己给他写一个了,那接下来咱们回忆先回忆一下卡夫卡单点启动的这个命令是什么。啊,单电器怎么写,应该是bin啊,下边有一个什么卡夫卡server,然后start.sh对不对,那这个直接回车能启动吗?诶回车试试啊,不行啊,他会告诉你这个怎么去用,Usage怎么用啊,后边呢,我们需要给他指明一个server proper,就是我们自己配置的那个文件啊,需要指明啊,那这儿呢,还有一个可有可无的东西啊,在这个咱们这儿有括方,括号指的是什么?就是可有可无对不对啊,那这个如果加杠demon,那你这个进程会退到后台,作为一个守护进程,那如果说不加杠demon呢,那就是组织在前台啊,那所以咱们这个需要给它加上杠demon啊,那那既然咱们知道这个单个的启动脚本,那群体咱们就会写了,哎,我们还是进到并目录啊,VM一个KF,诶,卡不卡点SH啊,然后呢,把咱们的那个群体脚本拿过来,呃,这个小文档里边有,那外边咱们那个大文档里边应该也有啊,咱们用外边这个吧啊。
07:45
That can it。来拿过来行,那看一下这个脚本的使用啊,这个如果说第一个参数等于start,那我就群起啊,群起就这么起的,那如果说stop,那我就群停啊就完事了啊行,那shiftz行了,那加直行权限甚至mode,然后加X啊卡卡点SH搞定了,诶啊没有加那个X是吧。
08:10
走。好了,已经变绿了啊,现在接下来我们做一个启动测试,呃,启动卡卡之前一定得保证ZK启动是吧,那我ZK已经起来了啊,刚才咱们已经起来了啊,已经有JK了,所以我现在可以直接启动卡啊K走。啊,那启动完之后呢,我们查看一下这个呃,进程S靠GPS卡不卡一啊,这个233个进程都在是吧?啊都在那接下来咱们去看看一下什么东西啊,看一下我们那个ZK上面的节点对不对,咱们去看一下啊,我们现在在哪啊,在这进到OB module就开,然后变ZK c Li点。SH好,咱们进来,进来之后呢,我们LS一下,看一下这个跟路径,好,你看现在这里边是不是就有一个卡不卡了呀,如果咱们那个配置文件当中不加上那个卡夫卡,那这儿是不是会一大堆乱七八糟的东西啊啊就是这个咱们看着就更清爽一点了啊,那我现在想查看诶卡不卡的那个信息,那你就进到卡夫卡啊,进来之后就这么一大堆啊,正常应该是这一大堆都在外边啊啊那我们得会看嗯,这里边的几个参数啊,首先我们先看哪呢啊,这个broke这个比较重要啊,咱们看一看里边有什么卡,卡里边有一个brokecas啊,然后这里边咱们呃重点看谁看这个iice啊,爱ice爱ice啊,这边012有012就说明什么呀,说明咱们卡不卡,这三台broker都正常启动了啊,这没问题的。
09:37
啊呃,然后前面给大家讲过啊,就是我们卡夫卡呢,呃,在启动之前需要掀起Z开,在关闭的时候呢。相关卡不卡对不对,这个原理主要是什么呀。原理其实就是这个位置啊,就就主要就是这儿,你看啊,卡不卡起的时候,我会在这里边是不是注册三个节点012对吧,那卡不卡,你执行它那个关闭命令,它会取消注册这三个节点正常应该就没了啊,但是如果说你关的时候呢,你没没使用它那个关闭的命令啊,你你怎么做的呀?啊,我先把JK关了,你关ZK的时候,是不是这仨节点没去掉啊啊,那你那卡不卡,呃,这个再关完了之后,下次你开机你再重新启动先起ZK,你会发现ZK刚起来就有这仨节点了,那卡不卡在一起,是不是还要在这注册呀,那我发现已经有了,它就不起了啊,就是这个意思啊,那所以说大家啊得注意啊,就是这个启动啊,这个顺序啊,然后还有一点呢,就是卡不卡你关的时候呢,可能比较慢,比如说我执行了卡不卡点SH这个stop了啊,它可能这卡不卡没有立即关闭,它关闭需要有一个过程,那所以说我们大家呢,得查看进程,等你这个进程当中没有卡不卡了再关JK啊不要着急啊,不要着急。
10:49
行,那先说这么多啊,把视频录上。
我来说两句