00:00
那接下来我们进行卡夫卡的安装啊,把卡夫卡的安装文档双击打开好,打开之后首先第一个事儿安装组件,第一个事儿干嘛呢?集群资源规划,那卡不卡怎么安装了,哎,我们在集群组件部署的时候,有这么一个点叫做啊频繁,哎有进行频繁的网络通信的,我们给它安装在一个节点上,那么JK和卡不卡呀,我们给它安装在一起啊好,那卡巴卡的安装首先我们先解压来到。这个地方啊,给它停掉,来到哪呢?CD到OPT software进来之后啊,我们把卡夫卡的安装包啊拿过来再给大家的资料里,哎,这里有一个卡夫卡啊,卡夫卡的3.0.0版本啊。哎,那前面这个2.1.2是什么呢?哎,这个是实现卡夫卡的这么一门语言,叫做skyla scala啊,它的语言的版本啊,叫做SKY啊,2.1.2的SKY啊。
01:08
OK,拿过来之后我们给它,哎解压一下啊,解压一下它杠ZXVF啊,然后卡夫卡啊杠啊C解压到杠OPT model完事,接下来我们CD到OPT model LL啊,你看我呢,也给它从那个名MV卡夫卡,哎名字就叫做卡夫卡好进来进来之后,诶进来CD-OPT model看不看啊,进来进来之后你看看第一个事是干嘛了啊,还记不记得第一个事。我们呢,直接来到count目录,然后修改谁呀,修改server proper啊,修改这个CD到count啊好,VI一个server VI'm server,那我们要改哪些内容呢?首先我们要给它一个唯一的broke ID吧,啊,那现在哈,102你啊是零,那对应的103你就是一呗,那这个呢,你是二啊这个稍后要进行一个改动,OK,那这个完事,接下来我们看看还需要修改哪一个呢?诶。
02:26
Log d,它代表卡夫卡的一个数据目录啊,我们要给它创建一个目录,等到这同样这个配置你也不要偷懒,我直接我寻思我这么的,哎,CTRLC给他拿过来,拿过来之后我看这,诶正好有空白地方,我给你右键粘贴过来呗,粘贴过来之后那就完了,为什么呢?往下翻。啊,往下翻你看往下翻啊,你看这个地方它也有一个log电压,你上面加载完了,OK,接下来逐行加载,加载到这儿,它把上边的给你覆盖掉了,那你这个没有用了,那它依然会把数据目录给我们存储到探目录下面,好,那不能这么干啊,那怎么办呢?我先把上面这个删掉。
03:10
那我先把上面这个删掉。好,那怎么办呢?我们呢,这么搜索,那你实在是不想找你搜索,搜索一个log,你看直接就定位到了,定位到了之后,我们来到这儿给它删除掉啊,删除掉之后我呀来这把等号右边的给它复制过来啊,右键粘贴啊,那有同学说啊,这些目录我们也没创建呢,哎,卡不卡,启动的时候它会给我们自动创建啊,那这个改完了再来一个好CK同理,这个参数啊,这个参数也不能直接复制啊,一定要在它这改动啊,一定要在这改动,往下翻就在下面,哎,就在下面。往下翻啊再往下,哎,这呢,你看这k connect啊,一定不要直接粘贴啊,改等号后边的。
04:02
人题好,那这个地方大家还记不记得什么意思了,你看JK的连接地址啊哈,多配1022181 103104的2181,那再来一个斜杠卡夫卡,诶,它是方便于我们卡夫卡集群管理,在ZK的节点上,我们呢,创建一个卡夫卡的节点啊,所有的跟呃,关于我当前这台卡夫卡集群的相关的这个数据,我呢都存储在卡夫卡这个目录下面啊,方便于我们管理,那如果说我再来一套卡瓦集群,那么我可以给他来一个卡夫卡二啊,那这样呢,避免呢数据出现冲突嘛,OK,冒号WQ保存哎,就更改这么三个地方,那接下来我分发吧啊分发CD要在这要在这XXYNC啊分发分发我们的卡卡。啊,那分发完了,对应的在103104,我们CD-OPT model卡卡啊修改一个内容,修改config目录下面的server properties,把它改成一。
05:10
冒号WQ,哎,冒号W冒号啊WQ好,那然后呢,把这个HRCD-OPT model卡卡进来,进来之后VI'm con目录下面的server pro4,哎,把这个呢,给它改成二好改成2OK,然后冒号WQ保存好了,那到这之后我们的卡不卡呀,也就算是哎部署完了啊好,那卡不卡,部署完了之后,别忘了我们还要修改一个环境变量啊,在环境变量当中,把卡夫卡的环境变量给它添加进去啊来吧,嗯。来到这儿。这好,速度VM-ETC profile.d下面的MY,因为点SH进来,进来之后卡夫卡的环境变量右键粘贴,然后你看啊,指定一个卡夫卡的安装目录,然后呢,这干嘛呀?哎,导入把卡夫卡的这个目录啊,加目录给它导入到系统的环境变量上,那导入卡夫卡的什么目录呢?导入卡卡的B目录,因为所有的脚本都在B目录里,然冒号WQ保存完事之后,我S一下SORCE啊杠EP-ETC profile.d下面的Yv.SH那这个文件呢,我也给它分发一下速度杠。
06:50
Home啊,艾特硅谷,艾特硅谷下面的B目录下面的XSYC分发ETC目录下面的和file.d下面的MYv.SH分发过来,分发完之后呢,这两个我们也S下SSOS-ETC profile.d下面的MY,因为点SH好,然后我E回。
07:18
那同理啊,这个104我也扫一下啊,复制复制完了在这右键粘贴OK,那完事之后我们你看啊。完事之后我们呢,就可以启动我们的卡不卡了,那启动卡帕之前,我们要先把主K哎给启动起来啊,那主K我们是不是已经启动了啊,那接下来我们启动卡不卡,注意啊,粘贴的时候别粘错了,不要只粘上面这一行,哎把下面这个con给带上,不然的话你启动不来啊。右键粘贴没事啊,来到我们的卡夫卡目录,右键粘贴没事啊,这也是右键。
08:02
粘贴啊回事,再来一个右键粘贴啊回事,OK,那么到这xca GPS那三个卡夫卡进程,哎,我们呢就起来了啊,那到这呢,卡夫卡的安装,哎,我们呢就完事了啊好,你看这有一个关闭的命令,那关闭的命令我在这儿就不测试了啊,稍后我拿集群启停脚本来测试,那同理,卡夫卡安装部署完了,我启动和停止都要来到不同的机器上来执行我们的启动和停止的命令,那在这儿啊,我们也需要一个卡夫卡的集群启停脚本,那么这个脚本我们是不是也写过呀?哎,那写过的东西啊,我们就不再重复写了,语言。哎,这东西你们写的应该比我都溜了啊,哎,你们应该已经写很多遍了,首先井号叹号B-BI,这是一个S脚本,那接下来我们通过case选择器判断我们输入的第一个参数,你是start呢还是stop呢?如果说你是start,我们通过for循环,诶,来到三台机器上分别执行这个命令啊,通过SSH执行卡夫卡的一个启动命令,嗯,那如果说你是停止呢?啊停止的话我们也是啊,通过SSH分别来到三台机器上执行一个来停止的命令啊OK,那么这个卡夫卡的启停脚本我就拿过来啊。
09:33
来到我们哈BOOK102加目录下面的并目录并,然后VM一个Kf.SH右键粘贴粘贴冒号WQ保存好了,那我再给他一个权限777啊叫做Kf.CHH,那接下来我们看一看啊JDS我们呢。啊,启动了,启动了之后,我们先测试一下它的停止s top停止啊,再来看看OK啊,你看这个已经听完了,那下边这个还没听完啊,它有点慢啊,我再看看。
10:15
OK,那到这儿已经停完了,那停完了我们再启动一下start啊启动怎么样。GPS。啊,这个已经启动完了啊,这两个了啊,这个已经启动完了,这个还没启动啊,我们再来一下看看。OK啊,0203,哎,零四的卡夫卡我们就都启动完了,那么我们这个集群启停脚本啊,到这也就完事了啊暂停一下,呃,那关于卡夫卡呢,我们还有一些操作命令,那在这呢,我们再一起复习一下啊,那我们看一看哎,给大家准备出哪些操作命令呢?首先我们查看当前服务器所有topic的一个命令,看看啊拿过来拿过来,来到哈102,我在这右键粘贴你看啊这是什么呢?哎,因为我们卡夫卡呀,已经配置了环境变量了啊,就不需要找到这个卡夫卡执行脚本的目录了,直接就能执行啊杠杠不得server哎,找到卡路1029092,哎,然后呢,杠杠list查看所有的。
11:26
Topic啊,你看现在没有,为什么没有啊,因为我们没有创建嘛,好,那接下来我们创建一个topic,创建一个CTRLC,在这右键粘贴,你看啊杠杠不断server,然后呢,杠杠create创建topic,我们必须要指定一个分区,然后同时指定一个副本,然后再来一个topic的名称,哎,这样啊才可以啊,OK,你看。创建一个啊,那这个创建完了,创建完了我再list一下。啊,没问题,好,那同时。
12:03
我们这还有一个删除哎,Topic的命令啊,那这个命令呢,我就不执行了,你们呢,想测试自己去测试建议啊,别删了啊,那这还有一个什么呢?查看详情的这么一个命令,我们看一看,CTRLC拿过来,拿过来之后右键粘贴粘贴杠杠describe啊查看哪一个topic详情呢?First的主题。好,你看我们这主题partan的数量是一个副本的数量,哎,是三个啊,你看这是partan有几个,是不是一个呀,那零号分区,那它的leader是零,哎,那以及它的副本的这么一个数量,还有isr队列的。哎,这么一个啊,数量啊,好,那大家可以现在就在脑海当中回想一下leader选举的这些流程啊,选举的流程在这我就不多说了啊啊在什么了,AR当中的顺序吧,哎,Isr存活嘛啊OK,那再来生产者的操作命令啊,那生产者我们给他拿过来看一看吧,看看我们的这个卡不卡,哎,它安装的好不好使啊,拿过来右键粘贴啊,卡普conso producer啊,控制台生产者啊,然后找到卡法这个机器啊,往first的主题写数据生产啊,卡到这了,那完事,我们再启动一个消费者吧,消费者那在哪呢?在这啊。
13:33
CTRLC拿过来,来到103啊,右键粘贴回去。OK,那么消费者的数据啊,也就啊,消费者的这个程序也就阻塞到这儿了啊,消费我们的FIRST2的主题,那接下来我往这儿写个数据啊,看那边能不能消费到,诶这边已经蓝了,那蓝了证明我们的数据已经消费到了啊好,那到这儿我们卡夫卡的安装了就没有问题了,呃,这个命令呢,简单的大带着大家就回顾一下啊,这个命令大家应该都敲熟了,哎,前两天也没少敲,行,那这儿我暂停一下。
我来说两句