06_尚硅谷_Kafka入门_安装&启动&关闭

呃，刚才呢，我们从基本的角度去了解了一下这个卡普卡啊，了解了一下这个科普卡啊，那接下来呢，我们就还是说来用一下，其实呢，它用起来的话比较简单啊，比较简单来看一下啊，那规划。K要启动了啊，不是说这块规划了，K说把K装一下，因为我们已经装过了，对吧，你要启动啊，你启动卡不卡来之前呢，要把ZK提起来，因为卡普卡是依赖于什么呢ZK的啊，它是依赖于CK的啊，是这意思啊，加不下载呢，呃，目前呢，卡不卡呢，这个东西也交给阿玛奇了啊，也交给阿巴奇了，所以他的一个官网地址就是什么卡卡点我这对吧。现在我用的是点的一个版本。

0.1这个版本好，呃，那这个下载呢，我们就不用去下载，已经下载好了，然后呢，我们拖到集群了。我不一定啊，应该是。Out，加PPCD的pd well啊扔到这个底下，然后呢，找一下我们那个夹包。搞不搞？资料驾驶里边呢，有一个这个。两个我们导的是这个0.1的。这上面呢，给大家留了一个0.8的啊，0.8的这个是早期的时候用的，早期的时候用的啊，很早都不用了，而且在生产环境当中呢，现在也基本上都更新到这个0.1了。啊一一版本啊，这个东西，那有同学说前面这个2.102.1什么意思呢。对吧，对，他是盖的一个版本，因为卡夫卡他是拿盖写的。啊，拿斯拉写的啊，拿斯拉写，所以说有的东西呢，我们呃也不就看原码了，不就看源码了啊，就是有的东西要去讲一讲啊，有的学讲讲，但是呢，他提供了一个Java的API，所以呢，在这块我们能去讲啊，能讲，因为我们现在还没学SKY对吧？啊还没学skyla，但是呢，更多的卡不卡这个东西还是拿Java操作的比较多一些啊，拿Java操作比多一些啊，我们就用这个，你不要搞错了，导0.80.8跟0.101差距还是蛮大的啊，差距还蛮大的，我们用这个0.111。

好，那这个就导进来了，导进来之后呢，我们解压一下CDOD收到。然后这个卡不卡。给你model对吧，CD到model里边，然后呢，我们还是改个名字。叫卡卡啊卡等会呢，我们还要分发，那我们进去要改配置文件对吧？啊另外一个框架都一样，那这个你看它这个文件还是蛮少的吧，啊并然后就没了，基本上就没了CD到这个什么。

那个里边还看一下。这个配置文件还蛮多的是吧？啊蛮多的，OK，那你看这个里边啊。又看到什么think source是不是啊，又看到这些东西，你不用管啊，啊，那我们要看这个，我们要改的是它。服务的一个配置啊，服务一个配置，其实你还能看到这里边还有一个什么的一个配置，但是我们呢，不用它里边的用我们自己的那个keepable啊，所以配置文件里边要求改啊，要求改，那我们重点的要求改，它其实你看到除了它之外还有谁的配置。消费者的配置信息和生产者的配置信息啊，这些配置信息呢，重点呢，都是给命令行来使用的，就是命令行也可以启动，消费者可以启动这个生产者。啊，因为做测试用的啊，但是更多的在代码里面的，我们就不会用它了，直接在代码里面去干什么啊，它这个配置文件相应的给它写上，那我们现在要改的是它OK点开啊，嗯，还是通过这个地方。

减到幺零。嗯。然后是这个卡不卡对吧。Confident里面有一个什么SOII点那第一个来看一下这个地方。他说这是broke的一个ID，那我们之前说过，Broke其实就一台服务器吧，啊，相当于就是卡夫卡的一个进程啊，等我要启动卡夫卡这个内容，然后说这个东西必须。唯一的一个，对于每一个机器来说是唯一的一个什么？整数，也就是说你不要在这给我来什么ABC了。对吧，啊，有同学就看到V1，然后写个ABC，他说了吧，V1的什么整数啊，你就不要不要做常数了，而且V1这个是零，那等会我们分发过就要改了，好，接下来是这个这个东西我们也要改一下，其实你不改呢，也无所谓，都要改一下好。

他说什么东西啊。设置是否可以删除这个主题？默认值是false，不能删除，那这个不好啊，说一个主题，假如说我们不想要了，是不是我们给它打开说可以删除啊，对吧？啊可以删除，其实往下走这个端口号呢，等我们要用的9092啊，它里边那个服务端口号我们也不改了啊，什么线程数啊，网络线程数，IO线程数啊等等也不改了啊，也不改了，好，那我们继续往下走这个地方。叫log DS。对吧，看着好像是卡不卡的什么。日志文件吧，啊，日志文件实际上呢，还真不是这块呢，你可以这样啊，你看这样，你以在这make d X log斯这样，但是这次呢，我们换一个，我们make DR一个。

Data。我make第一个data目录，两个都保留着，当然我们看一下啊，当然你如果说把log斯配进去也行。啊，那配置也行，到时候呢，你就会发现卡夫卡，我们今天说了卡卡呢，它是不是自存数据用的。对吧，啊，暂存数据用的它的数据呢，就放在这个目录。数据放在这个目录这个点log文件啊，是它里面存储数件的那个后缀名较高。啊，不是日志，当然日志它人家也叫log，就是说这个东西现在呢，其实不好解释这个点，因为人家叫log电压给大家的理解，那就是我正常启动或者使用过程当中反映的那些日志呗，对吧，但实际上这个地方的目录啊，它存的是卡不卡里边暂存数据的那个东西。

啊，那你要是这样吧，为了单好理解一点。因为这样最后就说就用六啊，我用这个目，这样是不是更好理解一点，可以吧啊，我用它大不了后面我们再改过来就可以了啊，我用这个目录，哎，因为我记得文档当中也是还是用的这个目录啊，还是用的这个目录啊。这运行日志它也放在这个里边，它默认的放在这了，默认的就放在这了，但是呢，这个log点电压是它一些数据啊，一些数据，那我们到时候给他看一下，就是你看到数据跟日志都存在这一个目录里边了啊好，那继续往下走，直接往下走，这个是默认的那个什么副本数啊，分析数啊，这些东西我们都不用改啊，你不用改，好那继续往下来看这。保留的什么时候要去干什么，删除的啊，删除的这个是什么啊，我斯吧阿斯是不是小时啊，我们家说了啊，你看这个地方它指的是一个什么东西的一个保存器。

叫。叫日志文件对吧，看着好像也是他这个系统日志吧，其实不是的，是我们所说的那个数据数据，他数据呢，数据存的文件名叫点到。啊，人家数据存的文件名叫点logo，它启动的那个名，启动的那个日志名呢，也叫点logo对吧？啊，它这个东西就是这样，还有一个那个log文件最大的一个大小。啊，最大大小这个应该是一个G对吧？啊一个G好，那接下来是这个内容我们要改了。他是不是这里边要配一个呀，对吧，不行吧，我们要改。哈，102。逗号啊吧，零三冒号二幺逗号。哈多吧，104冒号2181逗号是这告诉你的吧，啊，因为有的地方是不是配空格啊，有的地方配空配那个你要看一下它的视力啊，看一下他的视力这意思啊。

Crs就一个保存，其他的东西呢，我们就不用管了。其他同学不用管了，那你看一下关这个我们给大家的第一个是不是修改了一下ID。对吧，第二个。打开可以干什么，删除第三个数据或者日志的一个存放地啊，这个呢，你要这样配套，它数据跟日志都存放在这啊，都存放这，但是我们有办法给他区分开啊，有办法给它区分开，呃，就放在这，就这样。啊，最后。ZK的一个集群对吧？啊，ZK的一个集群这个意思，呃，环境变热呢，你想配配一下。你俩卖背一下，最好是还是配一下对吧？啊方便一点，因为到时候后来操作机器的时候，不用非得进到卡卡里边吧，啊不用非得进到卡卡里边是这意思啊好，然后呢，我们把这个东西配完了。那接下来应该干什么？

卡不卡啊，分发一下对吧，发下。好，然后分班是不是应该就启动卡卡。还有两个事情没有做，第一个你看到的是不是你还说了有一个唯一的因特类型的什么。不是个ID对吧，这个要改，第二个ZK还要启动，它依赖于CK的ZK不起他能起来吗？起不来啊，它会报那个什么超时连接不上那个UOK吧，好，第一个我们把第一部分给他连接上啊，103里边去改一下什么。我直接VI mod Mo这个卡夫卡里边con有一个点对吧，点开，然后找到这个什么。Broke ID啊，我叫012可以吧，这个改成一个一，保存退出啊，保存退出好，然后接下来这个地方直接VM一个OBD Mo卡夫卡里边有一个conf目录，有一个什么缩点，对吧？哎，这个VID1定要改，这是第一个我们要做的事情啊，我们还有两个事情要做对吧，这个呢改成二，你要保持不一样就行了，呃，你可以叫234，这个无所谓。

对吧，啊，这个无所谓，你叫V1就行了啊，你不要叫ABC啊，不要叫ABC，好，那接下来我们把ZK取一下吧。知道了。好，那接下来呢，我们看一下它的一个启动命令。C、知道并目录。L一下。命令挺多的是吧，命令挺多的，来看一下啊。关于启动的，那我们应该找什么stop对吧，那你看到了吗？到了。启动服务的对吧，启动服务的好，那你看这两个。这是什么？控制台的一个生产者和消费者嘛，控制台的生产者，那这两个东西呢，更多的是在测试环境里面用的，因为你在控台说把这个数据消费出来，那控制台消费数据只能干什么事啊。

就打印一下吧，其实意义不多啊，就是更多的是在测试环境，那这几个命令呢，用的比较多的，还有一个用的比较多，来给大家看一下，嗯，在我看一下。诶，哦，这个。卡卡点杠topics，也就是关于topic的一些操作都要用到它啊。topic的增删改查。刚才我们看到了，是不是可以说删除那个我们打开了呀，说明它能删吗？啊，它能删，但能删删的前提是内有啊，啊没有还有查看啊，增删干查，关于主题的所有操作都要用到这个命令，那刚才我们给大家看的这五个命令是我们后面学习当中要常用的一些命令，其他的命令很少用，在生产环境当中也一样啊，比较少用啊，相对来说还是比较少用一点的啊，少用一点的OK，那这里面呢，应该还有那个生产的一些测试啊，一些测试到时候我们要用啊，就是呃，做压力测试的我们也要去用一下，但是呢，呃，我们就简单用一下，之后呢，去看一下，这个是生产的测试。

这个生产的的一个测试，还有一个消费者的测试。嗯，有人看到吗？这。测试整个集群的一个负载能力的啊，抗压能力的这个意思，做压力测试的话，到时候呢，后面会去用一下，好，那现在呢，我们刚才所看到的应该用哪个命令去写。卡夫卡so start对吧？啊，但是你要注意这个时候呢，它是起不来的啊，起不来的他要加一个配置。文件把我们那个配置文件要指定一下啊，要指定一下OK，这个就可以启动了，而且这里边并没有看到像ID什么的。

起的。对吧，啊，群体的。肯定群集不了，因为至少我们有配一个什么类似于slaves这种东西嘛。你都没有，那102凭什么知道103104？是集群里边的内容了，对吧，啊这个呢，都是单节点启动的，而且来走。发现他还是一个色镜。啊，阻塞性成。那这种呢就很不好很不爽对吧，因为你要是再想用102是不是只能去干什么，再开一个很麻烦嘛，啊所以呢，这个我们不要不要我换一种。呃，我们官方提供了一种呢，在这中间加一个杠M。DEMO什么意思，哎，这个杠注意啊，不要不要跟那个中间加一个空格啊，守护进啊守好走一下。

没有日志看见了吧，啊没有这边。那你看到了多了一个什么卡不卡对吧？啊，多了一个卡不卡，那同样的道理，我们需要到103104上面把这个干什么。启动一下对吧，那这个其实还是挺麻烦的吧，所以我们应该做一个什么事呢？自己写脚本吧，啊自己写脚本，那我们把这个提起来CD到考管里边，OK，来走一下啊，那我们直接在这。X这边看一下。三台都起来了，没问题吧，啊，因为我们刚装的肯定都没问题，没有做任何事情啊，应该是好的啊，那这个呢，还是麻烦，你每次起的时候，而且生产环境当中，假如卡夫卡还是多呢，对吧，很麻烦啊，他没有提供这个学脚本，所以呢，我们自己去干什么，写一个群序脚本啊，写一个学序脚本，那还是拿它。新开一个新脚本，应该怎么写井号感叹号，我把它调成这个下啊，这样有颜色一点哦。

下。有几号好，那继续。怎么走，同样的，我们要群起群关，是不是也要写一下啊，它关闭命令呢，用stop啊，用stop那也很麻烦啊，那就用DOLLAR1，然后呢，In是吧。还记得吗？大的。还记得吗？之前咱了ZK那个脚本对吧？哈，多宝还写了好几个呢啊，让你们自己练一练没练啊啊现在又不会写，那这里边是不是起三台啊，三台就要用。

说循环了吧。In，什么好多102空格好多103空格好多104对吧？哎，然后do do什么东西要最后要到对吧？哎，这个正好想起来了，这个地方是不是也要写一下呀。对吧，这个还有个A，这个东西容易丢吧，啊这种东西容易丢啊，注意下都大他都什么东西S。Dollar I，然后发送一个命令对吧，那这个为了我们好看一点，我们是不是I可一个。艾，这个东西呢，由于那个。由于强迫症啊。我得。把这个拿过来。好，这个呢，就看着书位到CK一起对吧，他爸一起大家都一样，大家都一样好这个里边命令我们同样的要用什么。

全路径吗？全径。PWD啊，我应该到这个PWD到这吧，把这个拿过来，然后这底下有一个什么并目录，并目录里边我们来写一下B，刚才我们写的命令是卡夫卡。Start，然后是不是杠dae，杠DEMO，然后是直接这样写的，但是你不能这样写了。应该同样的配置文件也用决奏进吧，说也方便，是不是这样的，把他过来吧。看到没？OK吧，啊，这个是它的一个启动，那关闭就简单了，直接。把这个干什么复制一问，往那一放，这个改成stop对吧？啊stop这个里面stop改成道，那关闭的时候还非得指定那个配置文件吗。

关闭的时候还有一个什么守护进程吗？不要了啊，不要了，当然你加上配置文件也不会干什么，也不会错啊，就是你可以加一个配置文件，但是要看DEMO就不要了，因为是杠，DEMO是指的是将来启动之后以守护进程的形式存在，不是以什么。前台进程吧，啊不是以前台进程，OK，那这个就搞定了哦，CTRLS，哎，不是ctrl s ctrl a CTR c对吧？啊给它拿过来，那这个里面呢，我们去CDCD的并blue啊然后呢，我们touch一个直接VIKK点。哎，插入好保存退出，然后给他一个什么权限，K k.S走呃，然后K k.S因为我现在是开启的是吧，我把它关下关下。这不是这不提示吗。

不是我们只打印了这个呀。对吧，好指导一下这个好X一下这边。能关掉吧啊，但是呢，其实这个因为刚才有同学说没提示啊，所以说看了一下它有点耽误时间啊，因为正常情况下你在关KT的时候，就是卡不卡的时候关闭比较慢，就是你刚执行完，直接看GPS，可能103104还在啊，你等一会儿能听懂啊，它关闭的过程比较慢啊，稍微慢一点，跟其他进程不一样，但是启动。我们看一下知道了。X。启动没问题。启动的速度是比较快的，OK吧，啊这个地方呢，就是带着大家要把这个脚本去写一下，那自己一定要去写一写这种脚本啊，啊这种脚本。好，这个是我们所说的这个卡不卡，整个这个安装和。启动啊和关闭啊。