08_尚硅谷_Kafka入门_命令行控制台生产者消费者测试

好，那我们看一下，呃，刚才呢，我们是把关于这个主题的整个的一个操作给搞定了，就是增删和查对吧？啊查呢，包括呃，列出来有多少个主题，以及每一个单个主题的一个什么详情，我们也能查看，那接下来我们要用一下。你一直在说这个主题，现在也有了，那缺的应该是生产者和什么消费者，对吧？啊生产者和消费者，那之前我们看到。生产者消费者是不是有专门的命令啊？叫控制台的生产者，控制台的消费者吧，那我们给他起一下B。卡不卡叫？好，那你既然是生产者，你是不是得告诉我，你要往哪个主题生产？对吧，啊first first好，那接下来你往那个主题生产的时候。你连的卡普卡齐群，是不是要告诉我是不是连卡卡齐群啊，对吧，那尴尬，那这个地方呢，就不是连苏K了，因为我们说了卡不卡集群和consumer这块是要往ZK存东西，有说生产者这块吗？

没题了，这块呢，直接连卡巴迪群叫连broke。List brook这个东西很好理解吧？卡夫卡是不是博ID啊啊，就是讲的是卡不卡的啊博list啊这个呢，好多102冒号。还有谁当时在配置文件的时候，记得当时那个段子号一闪而过的。幺，这不就是，那要是幺那我前面不写了。应该确实比较难记住，就当时稍微提了一下，说那个有个动号，我们后面要用的对吧？啊，稍微挤了一下，记不住也很正常，9092，但是现在开始你要记得住啊。

啊，你要记得住了，OK，那这个是不是就够了，开挂集群主题。够了吧，这就够了。出现了一个什么小箭头啊，你在这呢，就可以出一些消息了啊，出现消息了，那同样的，因为你整个是一个集群，对吧，那我在103上去开启一个消费者是不是也可以啊，对吧，我在103上面去开启一个消费者并卡夫卡叫council。Consumer了对吧？Cons OK，好，你消费的也就是你第月的主题是不是要告诉我？你消费的主题不是订阅的主题嘛，对吧？啊，因为基于发布订阅模式的，你订阅的主题是一个first，好，那接下来他是不是也要连一个，就是这个作为客户端是不是也要连到集群啊，那他要连谁啊。他可以连黑，我们当时说了对吧，老版本里边不是吗？来看一下，我们联下看下。

好的，我102，那这个端口号是。181对吧，他因为连走一下。这边呢，有一个小小的警告，说什么东西啊。说这个康康是老的一个消费者。将来有可能被。就是说现在已经是什么被标记为过时了？将会有可能在未来的时间中找他干什么，移除对吧，移除他说让你用新的消费者去。不stop的来代替这个什么OK，我们上讲过在0.9版本之前是不是存在ZK当中啊，但现在呢，我们不是用的0.9了啊，0.9及之后呢，它存在本地，而本地呢，用不stop的杠so这种方式去列啊，等会我们连一下它虽然标记为过时了，你们知道过时的方法是不是还可以用，对吧，它可以用，那我们还同样的叫hello。

对吧，然后按什么。硅谷。硅谷。对吧，爱微博好，我们之前所讲的，你这是一个消息列这个呢，你要暂存说这个消费者啊，可以此时不在线，也就是说我此时在104上提个消费者，按道理来说，他那个刚才两个消息是不是也可以给他干什么。收到对吧，那才跟我们之前所讲的那个合理嘛，结果对吧，消费者此时不在线，只卡不卡，集群在那我随时在线就行，那我们再起一个什么。这样我直接把这个给他复制过来。发过来，然后你要想从头消费，因为命令行里面比较特殊，你要加一个参数叫from杠。

From beginning从开头的地方对吧？啊，加一个参数来。同样的，他也报这个。是不是两个消息能拿到吧，啊能拿到不加参数，这这个读不到啊，不加参数读不到，就是说他只能从最大的开始，这是呃，这是控制台，控制台这个它封装的一个点，当然我们在代码里面能看到，诶这个参数到底起了什么作用啊，在代码这个我们之前说过，无论在命令行里边做什么操作，他一定会掉到API对吧。对吧，啊，那这套所有的东西呢，我们都能在。API里边能操作的啊，在API里面能操作这个意思，好，那接下来我们是不是这个说过时了，过时了应该不好吧，对吧，我们就换一个这个呢，也不要了，我就不用测两个，我单独测一个就行了，那我按上我只需要把这个什么。

如C这个东西给它换成叫would stop杠，So。对吧，然后填哈多堡是本地集群，也就是说我们的卡夫卡集群叫9092啊9092，但是在测这个之前啊，来看一下啊。克隆一个。克隆一个。克隆一个，哎，我把这个东西给它放在一块儿，因为带大家要看一点东西了。搁这CD BD Mo掉，然后呢，到这个卡卡里边L一下这个勒斯。记住这个目录对吧，打扰一下log斯，诶不是在这个地方，后边这目录卡夫卡。下老斯。好，继续c DOD model卡不卡L下老斯看一下这个里面呢，主要记得什么呢，主题。是我们之前创建的，没问题吧，好，那我们前说过新版本它是将存在本地，那对于本地，这个本地我说了，不是说本地磁盘很注意这个本地指的是。

卡不卡指的是卡不卡能听懂啊，那既然你存在卡不卡，卡不卡存数据的地方。是什么？是主题。对吧，啊，它必须要存在主题里边，那你记一下这个内容，那我一启动。我把这个启动一下。我没有加杠杠，From beginning。没有消息消费的吧，啊这个呢，它是默认的，因为控制台里边呢，存最大的开始消费，那我再来一个，呃，爱德硅谷。到。可以消费到这没问题吧，只不过说前两条没加杠杠，服装B他们可以消费出来啊。那你接下来看一下这。哎，那不是。

那那不用说这个主题的名字叫什么。是不是到这后面这个数字就不用聊了，它是什么东西啊。不是这个一什么意思啊，那那你说他什么意思啊。那分区啊，他是一个默认的50个分区一个副本啊，默认的50个分区一个副本啊这个，而且呢，他也根据这个来了，你看这个博为零对吧，这哎102是不是博为零。它这上面呢，有一些内容。好，然后这个这个V1的。不V2的啊，岔开的，基本上轮许的方式，看见没零一啊在这儿，然后三在这四。

在这我又到102了，对吧，啊，轮许的一个方式啊，尽量的均匀的发送到，因为我们说了分区是主要为了做。负载对吧？啊，对于卡法机群来说，做负载均衡的，所以尽量的轮询的发到三台机器吧，啊，尽量的轮询的这样来发的，这个就是我们所说的系统的那个。存系统的内容的啊，后期呢，我们既然它是一个主题对吧，他是一个主题对吧，我们后期想办法诶用一个消费者啊，消费一下系统主题里边数据带大家看一下啊，现在呢，我们还没到那个点啊，还没到那个点，现在你知道它呢，其实存在本地，你要知道一个点，因为存在本地第一个不是说的本地磁盘。对吧，而是说卡夫卡本地，而卡夫对于卡夫卡来说，纯数据的只有一个地方叫。他啊，也就是说他的一个的一个off。

我们直接说过这个东西做什么事了。就给消费者来存消费者的位置吗？这不是消费者叫消消费者什么？配音量嘛啊，消费者的一个配音量也就这个意思，也就是说你通过这种方式一启动的时候，他就把这个主题给你创建好啊，在启动的时候他就不会创建了啊，不会说又来50个，那就疯了是吧？啊就这50个，当我们之前连足K的时候，他有这个内容吗？没有吧，啊，这块都没有的啊，所以呢，是由这个命令它存在本地啊，存在本地也就这个地方啊，那这个是我们所做的关于生产者跟消费者的一些测试。啊，一些测试啊，就是这个内容，包括那个杠杠for beginning，当然这个也可以加那个什么。尴尬from。杠BD。啊，刚刚说给那就消费到三条数据对吧？啊消费到三条啊，也就但是过了七天之后。

你就消费不到了，因为它是删了对吧？啊，最大保留时间是七天，只要你在七天内，你通过这个杠法不定都可以干什么。给他消费出来啊，都可以给他消费出来，是这个意思，这个大家关注一下了。