00:00
OK啊,呃,来这个是生成数据的脚本,然后呢,我们再来去写一个这个卡不卡的这个脚本啊,呃,这个卡不卡的脚本的话呢,这个之前大家应该都写过啊,比如说我叫什么Kf.SH,然后这里面我们之前大家写的可能就支持这么几个功能啊,一个是启动,然后一个是停止,对吧,就是我能够请你的服务,然后也能够停这个服务。对不对,好,但其实我们这个卡夫卡除了这个启停之外,我们经常还会用什么,用这个,比如说我想去做消费。对吧,我想去做一个什么消费的一个测试啊,或者我想去做一个什么生产的一个测试。那你在消费的时候,你要写这么一大堆,你生产的时候你要写这么一大堆。对吧,你看这是消费,比如说我写一个生产,生产的话就是相当于是这样子的啊,就是卡夫卡杠pencil producer,然后杠杠什么ER。Broke-list,然后后面是写个102,然后呢9092,然后后面是topic,你就写上你的某某某。
01:00
对吧,你要写这一堆。但其实你发现你不管生产也好,还是什么消费也好,前面这一堆是不是都是固定的呀?前面这一堆是不是都是固定的,唯独不一样的不就是后面这个topic不一样吗?对吧,那我就可以考虑把它写到脚本中。对不对啊,所以你看我这个脚本怎么写哈,来第三个就是这个卡夫卡脚本啊,卡夫卡这个脚本啊,呃,怎么写呢,这个基本的这个启动停止我就不再给你写了啊,这个你们一下都写过,我就直接复制过来。呃,我都复制过来得了哈,我给你解释一下吧,这个我就不给你写了啊。对吧,大家之前都写过的啊,来看一下。呃,首先还是我先判断你的参数,因为你这个卡不卡的脚本,它是一定要传参的啊,你不管是启动也好,或者什么停止也好,对吧,都得传参啊,但这一次我们再带上一个卡夫卡consumer叫消费卡夫卡producer叫什么呀?叫生产。对吧,所以说呢,我要判断你的参数,如果说你没有参数呢,我就提示你一下,说这个脚本怎么用呢?是Kf.SH后面你要跟上你的start也好,Stop也好,KC也好,KP也好,这是生产,这是消费,这是生产。
02:12
对吧,好,那假如说我们传了参数了,那我就要判断,如果你是启动,那我就执行我启动的逻辑。对吧,我们用什么杠server start,然后呢,去启动指定上你的配置文件。这都是你之前写过的,我就不说了啊,如果你是停止呢,诶,那我就什么执行这个停止的逻辑,好,那如果你是KC或者KP。那我就要求你还得再传一个参数,传什么呀?传你的topic进来,你要从哪个topic消费,你要从哪个topic往哪个topic去生产。对吧,你就得什么把这个topic给我传过来,所以说你看我的提示就是。KC后面还得加个topic kp后面还得加个topic。啊,那如果说你是KC或者KP,那我就要判断你有没有第二个参数。好,如果说有,那你看我就可以怎么写呢,就是cons consumer,然后呢,指定上你的地址,然后呢,杠杠topic,我把第二个参数往这一放,这不就相当于从你的这个topic那去做消费了吗。
03:12
对吧,好,那假如说你没有传,那我还是提示你类似的告诉你,你必须得传一个什么topic,传一个topic。对吧,如果说你是KP也是一样的,那我走的就是producer。对不对,然后指定上你的这个卡牌的地址,然后呢,官方topic后面写的是DO2,这个表示的是我要去做生产了,往这个topic里面去做生产。能理解吧,好,那如果说你没有传第二个参数,我也是做相应的提示。好,那除了你的启动停止这个消费生产之外,那别的你传的疑虑的东西,我都告诉你,这不对。啊,当然呢,其实大家呀,还可以再去做补充啊,比如说我再补充一下什么呀,补充一下这个东西。叫什么呀,叫。Correct对不对,那你可以想把这个创建这个topic,它的操作是不是也写到这里面了。
04:08
对吧,或者再补充一个什么叫做delete对吧,删除的啊,或者再补充什么呀,再补充这个叫做。就是我要去查看你的详情的,或者补充什么,补充这个什么list,就是我要查看你这个所有topic的列表,你是都可以补充进来呀。能不能看明白同学们啊,像C的话,我觉得你可以不补,不补充也行,因为它默认会帮我们创建啊,这个删除你可以补充一下。对吧,描述可以补充一下,这个查看列表可以补充一下。对不对啊,都可以啊呃,来吧,那就说到这,那我就补充一下吧,好吧,补充一下啊,行你看了啊补充一下,嗯。这个创建我就不补充了啊,让他自己创建来先补充一个查看详情吧,把它拿到上面。好,先把结构写好哈。
05:00
然后呢,在。把这个也拿上来啊,我们先补充这个。详情啊,然后再补充最后的这个删除。对不对啊,你都可以把它补充进来啊。好吧,行,那如果这个要补充的话,那我这个所有的提示我就得换一下啊,所有的提示我要换成这个东西,就是呃,我可以启动停止,然后呢,可以什么呀,这个消费可以啊生产,然后呢,再来提示啊可以什么呀,可以这个叫做嗯list。对吧,那类的话,后面你也得啊list不用跟啊,然后呢,可以什么呀,可以这个叫做这个delete。啊,那话你得告诉我你要删除的是哪个topic对吧,然后呢,可以什么呀,这个describe啊describe你也得告诉我你要提示的是哪个topic。对吧,对吧,我把这个补充呢,我就来稍微再再小一点啊。好,我把这个所有的都替换一下啊,所有这个提示的地方,我都给它替换一下。
06:04
诶,啊,对着呢啊。好,这里面也是。拿好了吧,行,下面我就把这个代码补充一下,如果你是一个list list我们怎么走呀?同学们,List不就是卡夫卡杠topics加SH,还记得吧?同学们来找你的卡夫卡的命令啊。这就是考验你对这个卡夫卡的这个命令用的熟不熟了啊,这里面是不是有一个叫做卡夫卡杠杠杠topics呀,对不对,然后它里面用什么呀,如果说你不会用,你可以这么去写啊,就是卡不卡杠。到topics好,直接回车,它会告诉你这个命令怎么用,你看这里面都是你要加的东西啊。对不对,现在比如说我们想去做list,那你看一下你这刚刚list是不是有啊。对吧,好,那就把刚刚list写到这,你看了哈,刚刚list写完以后你再回车。
07:03
他会告诉你说你丢了一个什么非常重要的这个配置叫什么boottop server OK,那你再把它加上boot stripp-server,那我就写个哈102,然后呢,9092,我多写几个啊,1039092。104,然后呢,9092对吧。好,这样不就看到这个所有的这个就是主题了吗?对不对,那你就可以把这个拿过来了呀。拿过来,往这一放,搞定。这就是我类的功能。然后呢吧,好,那如果说你要做这个描述描述的话,就我就不再给你测试了啊,它就很简单,描述是这样子的,把这个改成什么刚刚,然后呢,后面的话呢,你再跟上一个刚刚topic,呃,那你就要什么传你的这个topic了啊,那我就要什么去做判断了啊就是。If你必须得有第二个参数啊,找到二对吧,如果你有,那我就做这个操作,那我把这个DOLLAR2就写到后面对吧,那else就是你没有的情况下。
08:10
对吧,如果你没有,那我还是这个提示一下,就把这个提示一下就行了啊。对吧,提示一下,然后呢,这个Fi这就搞定了。能看到吧,好,那如果说你是这个delete delete也是一样的,Delete就是还是要判断啊,就是如果说你有这个第二个参数。叫呃,这个到差点写错啊,空格空格不能忘啊。到了二对吧,然后下面就是来then好,后面怎么写呢,还这一堆呀。对吧,只不过你只需要把这个换成delete就可以了。然后呢吧,然后呢,下面是这个,呃,叫这个else else还是一个提示啊。行,后面是这个Fi,这就搞定了。对吧。
09:00
当然这个脚本写的是比较啰嗦的啊,你可以把这个脚本再去做优化啊,优化的这个更更更什么呀,更这个简洁一点也可以。对不对,行吧,那么写好了,写好以后我们来做一个整体的测试吧,啊,我把这个复制出来,呃复制出来以后来复制出来我们放到我们的这个脚本中啊呃,来到这个,来到这个加目录啊加目录,然后并目录里面好然后呢,我们改一下,我原来叫KF啊,那我就呃删了吧,重新创建一个啊Kf.SH好过来以后呢,把它放进去,放进去以后呢,保存退出啊。好,接下来给权限k.SH好,呃,那我们先来看啊,这个现在我是有,现在我是有这个卡夫卡的,那我先停一下啊Kf.SH,比如说我什么都不传,它就会提示你这一堆对吧,那我传一个,比如说我想停掉,那我就stop。
10:00
好。稍等一会儿啊,因为他这个停会慢一些啊。这个还没停掉是吧,我们再再来看啊。没了吧,好,那我测试下起啊。嗯。好看一下。能起吧,然后你再测别的啊,比如说KF点,呃,我想看这个list。你看这就是所有的这个主题就给你列出来了。对吧,那比如说呢,我想看这个具体的啊呃,我找一个啊,比如说我们刚刚的这个1018就看这个哈,来Kf.SH我想看这个好把它往这一放。行,这就是你当前这个主题的一个什么详情。对吧,你有这个几个分区啊,几个副本。是吧,这个相信我是能够看得到的。OK吧,好,呃,然后呢,还可以干嘛删除,删除的话,比如说我随便删一个吧,呃,删一个这个。
11:08
我就把这个删了吧,就把这个删了啊,来就把这个删了。好,杀完以后你再来去list看一下,它就没了。对吧,就没有那个主题了。看到了吧,同学们啊,说这就是,呃,一个脚本的一个编写,就是你你想让它有什么功能,那你就把这个功能给它加进去啊,对于我们这个使用来讲,我觉得你也没必要纠结说那我这个脚本写的简洁不简洁,功能强大不强大啊,我的认为就是我写出来这个脚本能够帮助我去简化我的操作就完事了,那可能我写写脚本我花了一点点时间,但是这一点点时间的牺牲是很很是很值得的,因为你后面你再去做类似操作的时候,你直接通过脚本就能做了,你就省的去写那一大堆的这个代码了。明白吧,啊,所以你这个实际将来做开发的时候,就一定是前期的准备工作,肯定是,呃,这个这个比较漫长的,那你把这个一套需要准备的东西都准备好了以后,那你以后再去写代码的时候,你就会很顺手,你因为你写到某个环节,比如说诶,我想用一个什么功能呢,我前面已经准备好了,那我直接去调用。
12:14
对吧,我想去实现一个什么什么效果了,我想去测试一个什么什么东西了,诶那我前面准备过这个东西,我直接去调用,你就会写的很顺手。理解吧,但如果说你这个前面没有做这个类似的准备,那你每次用到这个功能,你都得重新做一次,每次用到功能你都得重新做一次,那这个其实就很麻烦了。好吧,所以说呢,呃,你牺牲那么一点点时间,然后呢,去做一个准备工作。是很值得的,对吧?老话也说得好,这个磨刀还不误砍柴工,对吧?啊,你先把这个刀磨的锋利一点。对吧,后面这个你在用的时候就得心应手,很顺手。OK吧,行,这是我们这个卡夫卡的一个脚本啊好,那我目前的话呢,就给大家去呃,讲解这两个脚本,那当然别的脚本你也可以去写啊,比如说这个我们要提主K本,那主K的脚本你们应该都有。
13:03
对吧,那等我们后面的话,比如说我们还要安装各种东西。是吧,啊,比如说这个ES,那我写ES的脚本。对不对啊,等等等等一些你都可以把这个准备成这个脚本,然后你用起来会非常的顺手就完事了,好吧,来,那我就说这么多啊。
我来说两句