37_尚硅谷_数仓采集_Kafka集群启动停止脚本

好，那下面呢，我们就来看一下这个卡玛的群体脚本啊，群体脚本啊，那这里面。简单写一个吧，是吧，好久不写了，感受一下好吧，回忆一下，那写一个小本，那就是井号叹号变S，好，然后先写它的架构啊，K分之，然后传进来DO1啊然一啊，然后呢，它传进来这个DO1，如果是start a括号，然后大括号里面内容，然后分号，分号结束啊再来。那这里面stop。好。然后EAC。二号吧，没有东西。啊，这个是E，呃，EAC就要结束了，OK，那剩下的就是要写主干里面的具体的内容，那这些内容的话，那很简单，因为我们卡罗法是三台，那就记住是几台，你就循环变列几啊一。

还洞房102还动房103还豆和1044坦，然后在这个cell里面，那度和大代表了一对括号啊，你可以认为是括号，然后在这里面s sh do I取出它的值啊根号到对应的节点上执行相应的命令啊，那这几个命令呢，就是卡卡这个启动命令啊，那这里面用的是这个啊杠DEMO啊，对守护进程啊，也是在后台运行的啊好，那就说这个卡不卡启动命令啊在这，然后当DEMO它的配置路径在这位置，这里面要注意的就是它的路径是绝对路径啊就OK了，那这里面还有一个s part g Ms part啥意思？

嗯，JS是什么知道吗？监控端口啊，它是一个监控端口啊，你可以拿过来说，它是用来做这个程序监控用的。嗯，这个GS100度百科GMS啊直接看这一块。所以看这块吧，呃，GMS在Java编呃，编程语言中定义了应用程序及网络管理和监控的体系结构，设计模式，应用程序接口以及服务，通常使用GS来监控系统的运行状态，或者管理系统的某些方面啊，主要用来第三方监控的啊，这么这么一个端口，那这里面为什么把这个端口提前给声明了呢？

嗯，因为我们在这个卡尔manager里面啊，需要这个端口号，那同学说你们在讲卡普卡manager时候应该没配置的吧，啊应该是没配置的，其实在这个卡法manager里面，大家在配置到哪个地方呢。诶，这个页面啊，这个卡法麦的页面，它的下一级GI Ms什么user，其实是还有几个参数需要配置的，如果上面这个端口你没打开，那正常下面这些功能你就实现不了啊，如果你想把这条簧在所有功能都实现的话，那你要把这个加S这个端口啊打开哈，所以说它是为了这个G啊，也是说PA manager做准备的，所以这里面啊，我们声明一下。哎，所以这种脚本啊，非常简单啊，然后之后呢，下边这一块啊，那就是停止呗，啊停止。

那停止的话，前面这个就不用说明了。然后这块就变成了，然后后面还有吗。干掉这样就干掉了啊，完成了啊，比如说呃，这个食道啊，应该没有也行，这倒是啊，可以试一下好吧，啊试一下这个没有应该也行啊，那这个呢，就是卡卡这个啊机器脚本，那我们来试一下看看能不能用。OK。CDCDD不漏啊，来到这里面VKf.SH啊看看。好。车子帽的77KF。OK，搞定搞定之后，下边我们就来用一下这个脚本KF点顺序。

这个打印的日志有点多是吧。诶。发现了什么情况？是不是还留了一个啊，留了一个，那那这种呢，就是这个网络上有一定的这个延时啊，你再看一下。看到了吗？啊，比如说卡罗卡呀，他在这个关闭过程当中，其实他这个关闭这个时长啊，非常非常长啊，它保留保存一些很多一些状态和信息啊，那这就带给呃，带给我们一个问题哈，日后我们在写这个整个集群这个停止脚本的时候，比说最后4.7这一块。那卡不卡，这就必须得等待它完全的退出之后，才能执行后续的操作，尤其是关完卡片之后，这卡卡没有完全关掉，我们就去关这个主keep的时候。

就会出现。如果主闭门一旦停止掉，卡帕再也管不了。除非你keep掉它，因为卡卡的状态信息保存在主keepper里面啊，那主keepper已经挂掉了，那它就再也关不掉了，所以说那在他们俩之间就要加一定的延迟，网络延迟，每台服务器的这个延迟时间不一样啊，这个需要去调试啊，这是引出任何一个问题啊，比说插挂它的关闭呢，时间呢是比较长一些的，行，那这是这一块，那下面这这几节呢，是个像这个查看卡卡的topic列表啊，以及这个创建topic个删除topic一个啊卡卡生产和消费是我们之前上课讲过的内容啊，至于放在这是方便后面我们调试手页，比如说验证这个卡普卡是否能正常稳定的运行啊，所以说把这个命令放在这了啊，行，那我们来看一下，那大家说目前这个卡帕里面有没有投屏啊？

我记得这次有一个网球召唤者主的奥。哎。什么情况？怎么默认就有了两个topic，我明明没有创建它，为什么就有呢？而且还起的名字跟我的名字一模一样。很奇怪是吧，什么原因？前一节是母后一节好不好？前期不中。放进卡卡，那这个pro这块我们用的是卡夫卡传啊卡法。对应的start对应的，那其实他们在往这个卡卡里面发送数据的过程当中，发现这个卡卡没有topic，那就自动创建。

OK吧，这要注意啊，它它们俩之间一旦它这个螺母先启动之后啊，那只就自动的去往里发，那发的话，你这边没有，我就给你创见。这个插件啊，那这里面那就要注意的东东西了，那你说你在卡瓦这一块，你去删除topic的时候。你前边from要是不停止，你觉得你能删掉了个毫屏删不掉了，因为你散完这边创建，一删完就创建，那就出现这种幽零现象了啊，那这时候怎么办呢？你可以要先把前一集那个from先关掉，然后再删除这里面的topic OK吧，这要注意啊，注意卡坡上给你创建好了，好，那目前呢，这个是呃卡卡就已经OK了。那之后。那我们要验证一下这个跑法OOK啊，那你需要再进一步的测试，测试它的生产能力和消费能力啊，那好，那这里面首先呢，你把那个。

KA的消费者打开啊，消费者那就是KA啊，然后杠杠主keep from从头开始消费对吧？那消费的topic是topic哪拿过来。搭完这个打款机器之后，一定要自己去先测试一下啊，证明这个东西是OK的啊，然后进行下一步的这个操作哈，行，那目前这个消费者已经打开，那我们再来一个生产者。OK。正开车，然后哈喽。在吗？啊。

好，那这个你卡法都关了，肯定是连不上的啊，这不用想啊，那连不上的话，那我们先把这个卡法先启动起来KF啊，这就跟那个之前有一个学生啊，他遇到一个bug，那是spaug的问题，他说spaug老师我这个程序我抑制不了啊，然后说我整了我研究了一天啊，一天这一天一宿我都没睡好啊，然后给那一看，发现S那ug没启动，然后说怎么提交都交不动啊。好，那这个卡不卡，我们来看一下。哎，那这样谈话就启动起来了，启动起来之后，我们要设置一下这谈话，把这个消费者打开。这是基本的一个测试啊，作为一个程序员的话，你写完任何代码都要测一下，这是比较好的啊，好看这啥意思啊，为什么上来就有啊，我是不是from beginning了啊beginning那就说他原始的一些数据我就要给他啊，消灭掉啊，这么多数据，那我现在不用证明它好坏了吧，现在应该是有了。

那你也可以吧，再进一步证明一下。Hello。没变没变了是吧，看到了，嗯，那这样呢，至少现在能证明一件事，你的卡不卡是OK的啊，而且呢，前面看到这些日志信息说明他的也是OK的啊，你就卡法目前都OK了。啊，那他们都OK之后，那剩下的事就要往后做了是吧，那往后做之前，这里面我们还要做一个这个卡不卡的麦监控啊，比如在争论的其发中呢，像这个各种程序的这个监控啊都要做啊，比如说监控卡不啊卡卡的监控卡卡manager，卡卡monitor啊这些都是要做的好。