00:00
好,上节课我们是采用手动的方式,把卡卡呢,一台一台的启动起来了。那么在生产环境当中,我们能不能这样去做呢?很显然这种效率啊,非常低,我们一般呢,会写一个脚本来帮我们去管理卡瓦的启动和停止,之前我们写过这个,呃,Hadoop和主keepper的,那这里面呢,再给大家写一遍好不好的?这个呢,非常简单啊。来写一下井号。叹号列。Best剪辑器,然后呢,Case分支传进来一个参数DOLLAR1导一,那么如果你传进来的是start,那我就进行start相关操作,如果你传进来的是stop,那我就处理stop相关参数E。那下面呢,For循环IE。HIOP102103104,比如说我要循环便利三台服务器,然后进行一台一台的进行操作。
01:00
Sh Dollar。那记住这个脚本这一块一定要写绝对路径啊,要写绝对路径,那好,那我们先把这个命令先拿过来哈。那把它拿过来,这是卡巴启动的命令。那这块你要不写绝对路径,写相对路径,那你这个脚本写完之后,是不是就只能在这个卡不卡安装这个目录下进行使用啊,那你后续再换一个路径,你这个脚本是不是还得进行修改,那可一致性呢就比较差,那通常我们会怎么写呢?都写绝对路径。OPT。Model。好不好好,那这个完事之后,别忘了后面还有一个config把它。给一个绝对路径啊,搞定搞定完之后呢,这块呢,你要稍微完美一点呢,就是E。告诉这个用户,我现在在干的事呢,叫启动。第几台?
02:02
好不好?对吧,哎,这样去做。可读性啊要更好一些,那下面呢,把这个代码呢,已复制。把它改一下,改成对应的叫停止。那下面这个start脚本呢,也不行了,哎,换一个叫stop。后边对应的参数直接删掉。OK,这个卡巴启动停止脚本就已经写完了啊,非常简单啊,那我们来测一下复制粘贴。CD。啊,来到自己家目录下面的并目录,在这里面创建一个KF。谁去走?进来。保存退出。帽子77KF。行,那现在这脚本就写完了,那接下来呢,我们要用这个脚本进行一个测试。那怎么测呢?啊,非常简单啊,Kf.stop。
03:03
哎,停止卡卡集群,那这个地方注意了,你看我调用了停止命令,它并没有立即的停止掉卡卡,因为啊卡卡集群停止的时候需要一些时间,你看过一会儿的时候它就OK了。那这里面容易引起卡夫卡集群第二处出现问题的地方是什么呢?一定要注意,就是要先关不卡,而且要等卡不卡所有的进程都停掉之后。再关闭对应的主题。那如果说卡卡集群没有正常的停止掉,你就着急的把主K干掉,会出现什么情况呢?那这个卡法进程永远也关闭不掉了。那你只能Q杠九把它Q掉。那为什么会出现这种情况呢?主要原因是因为卡夫卡。他是不把一些信息存储在了主里面。那么如果主K班下线,那主K班在停止之前,他要先跟主K班通信一下,看一看他当前状态。
04:05
但是他已经连接不上主题本了,所以说自己他已经停不掉自己了。啊,所以说这地方一定要注意哈,对于新手来说,愿意出这种问题。那行,那现在呢,这个卡把停掉了,停掉之后呢,我们起一下啊KF调用start走。启动。哎,它启动的速度呢,还是非常非常快的哈,行,那现在我们这个卡法启动停止脚本就已经完成了哈。
我来说两句