尚硅谷基于腾讯云EMR搭建离线数据仓库（2023版）/视频/023-腾讯云EMR-离线数仓-Kafka服务群起&测试.mp4原创

刚才我们将卡夫卡服务呢，已经安装完成了，那接下来呢，我们得去测一下这个。集群是否可用对吧，那我们得启动测试啊呃，启动呢，矢量卡夫卡呢，它并没有。提供一个群体脚本，它只能通过这个命令去单独启动某一个节点，以及通过这个命令单独关闭某一个节点，所以未来在生产环境当中，当我们集需数量比较多的时候，那我要单独执行就会很麻烦，所以这个地方呢，我们准备一个脚本让它群起啊群关，这个脚本呢，相对来说也比较简单。那未来呢，我们。直接连的都是101MASTER节点，所以我把这个脚本呢，写到这个101上面啊呃，PWD一样的到先是这样啊，CD回来对吧，在这创建B目录，然后进到这个B目录啊，然后呢，我们去。诶这边呢，我好像之前是有的，我把这个删掉啊，然后呢，VMK k.SH然后呢，哎，插入把我们这个脚本给他拿过来。

拿回来之后呢，带大家看一眼啊。在这边首先。K到一，也就是说未来我们调用K k.SH这个脚本的时候，我们需要传一个参数啊，那我们这个参数呢，如果是stop，那走这里边的代码，如果是stop分支嘛，对吧？啊我们都写过代码，然后呢，这里边儿是一个负循环，1031041053台机器，然后打印一句话，启动每台机器上的卡夫卡。最重要的这个SSH协议到103DOLLAR I，注意这个I呢，在循环当中分别代表。这三个啊，那接下来刀就是分别代表103045，然后执行的命令，就是刚才我们看到的这个。好吧，那关闭也一样，执行我们的关闭命令就好了啊，这个搅拌的比较简单，然后呢，我们。退出来change mode，然后呢，U加X给它附上我们的执行权限啊，那接下来呢，我们就去启动，在启动之前呢，咱们先去看一下这几台机器上的服务。

只有did not not manager。幺零四一样对吧，105我们看一眼。一样，也只有这个note manager跟data node，所以这个时候呢，我再去调用，诶输入start。啊，启动，然后接下来我们再来看这个GPS多了一个卡夫卡吧。多了一个卡夫卡啊，同理这边呢也会多一个卡卡，那现在呢，我们集群是起来了，但是否可用还不知道，所以呢，我们要创建一个主题，用控制台的生产者跟消费者去简单测试一下。那这边呢，我们。出来。嗯，卡不卡。啊，创建主题大家可能不太熟悉，或者说有同学之前学过，但是忘了对吧，没关系，Topic啊用这个命令，然后呢，刚刚create。

刚刚要连接我们的集群。So。啊，那我们用哈杜103啊，那我们可以写主机名了，因为我们已经把。主机名跟。IP的映射。八台机器全都一样了，都有了对吧，他们都互相的认识啊，而卡夫卡的端口号呢，是9092啊，然后给一个主题的名字，那我们测试用test，接下来还要指定分区数和副本数。分区partitions，那比如说我们给两个啊，那我们也不要一个杠杠，然后呢副本。然后呢，我们也给两个。快撤。诶，那创建了这个主题test，接下来呢，我们在这儿搞一个伸展者，到另外一个机器搞一个消费者，对吧，我们来看一下这个是否能正常啊呃，那伸展者呢，是卡夫卡。

啊，然后呢，连接。杠，So。哈，102冒号9092杠杠主题给一个我们叫test。呃，啊，这个地方呢，我们是生产者，生产者呢，这边应该写Li。他这个其实在我们API里边都已经统一了，无论是生产者还是消费者用的都是这个叫，但是这个命令行呢，它还并没有改啊，这个要注意一下。他说连不上对吧，我们看是不是自己挂掉。

嗯，没有挂掉。啊，这个地方不好意思写错了，103啊103对。因为我们装在103 103105，我在写102啊，这个肯定不对。好，那这边呢，出现了一个大于号，那说明可以让我们输入啊，这边呢，我们来起一个消费者，并叫卡夫卡。Consumer啊，那一样的不得这个地方啊，它用的是不。好1N3啊。然后呢是9092端口，然后我们主题一样的是test。好，那这边呢，没有报错，说明他已经开启了，那接下来我们在这边打一个好。这边就有了，对吧，比如说来一个爱的硅谷。诶多多打了一个点，诶这边呢，一样的有对吧，那这样的话我们两边通信就通了，那我们卡夫卡服务呢，是可以正常启动并给我们提供服务的，那这个就OK了，对吧。