21_尚硅谷_Kafka高级_消费者组案例

好，接下来我们看一下这个消费者组的一个案例啊，消费者的一个案例来看一下，呃，这块呢，我们要去改一个参数，还是同样的改这个内容。那我们改一下来。CD。到咖啡里边。叫consumer，因为如果你不改的话，它默认的是给一个什么八五乱七八糟的吧，你每起一个他都给一个新的，你每起一个都给一个新的。那这个时候有问题，我们不能错同一个组啊，所以我们得给呀，哎，给什么组呢？爱的硅谷组。爱V股组，好，这个时候启动消费者来，还是同样的这个地方呢，生产者我还放在这儿，还是用这个big data OK吧，那接下来我启动一个什么。消费者。Cons，然后杠杠我连因为好看一点啊，在里边因为静态的对吧，他不像那个呃，存到本地，然后呢。

轮一直在刷吧，啊不方便看，我存在UK吧，因为我们现在知道，其实无论存在UK也好，存在本地也好，那存的东西是一样的吧，对吧？啊所以呢，我们存在UK，因为这个好看一点。2181。2181，然后是我们的主题对吧，叫topic，叫big data还是用刚才那个叫big。对的，然后这个时候呢，应该指定一个额外的内容了。就是指定我们什么。Consumer的配置信息，如果你不指定它是不是还是随机分配一个数字，那你启动两个，那不是两个随机数字吗？不是一个组嘛，现在我要他一个组啊，要他一个组，要加上这个叫杠杠。Consumer点。然后是con底下什么啊，走一下。他同样的该警告警告对吧，好这个时候呢，我们同样的进到ZK里边去看一下。

啊，之前我们是不是说的那个地方是组名啊，对吧。CD，然后打开这个客户端嘛，并目录z k client.s走进来LS一下根目录。还是同样的，看那个吧。嗯。大家看是不是刚才那个什么八五那些东西没了，因为它是临时节点啊，你起的控制点的消费者，如果说随机分配的名字是临时节点，你一旦把这个关掉，它就没了，它就没了，但是他现在我只起了一个消费者，他居然有三个。这两个东西大家还有印象吗？是它的一个默认值。Model卡不卡卡看了一下什么？叫group，看见没，这个叫什么？

给把ID，刚才我们是不是把格把ID改成I硅了，那你看现在多了谁啊。这个现在能证明这块写的是组名了吧，没问题吧，好呃，然后这个是不是我当时消费了一次CRC之后说组名已经有了，不行对吧，因为控制台消费者，如果你消费者是系统分区的话，他不允许那个组名之前存在啊，所以呢，我当时改了个名字加了个一对吧，所以两个组都有，现在我们是不是爱的硅谷啊，爱硅谷好，那正常的消费我们看能不能消费叫hello走。能消费到没问题吧，啊拿这个东西，那我再打印一个，是不是理论上，因为我们的这个big data是不是两个分区啊，当时。Big data是两个分区，没问题吧，当然我们建了两个分区，现在我们也知道它默认的是不是轮询，现在是不是你当前这个消费者消费了。两个分区的数据啊来，接下来我把其他的都关掉啊，防止干扰对吧，这个CRC。

嗯，就搁这CD回来到卡不卡这个102，搁这103呢，我给他干掉，我此时呢，再去启动一个爱的硅谷组里边的什么。消费者。又启动了一个，启动一个之后我再来打印哈。好在这个地方，那接下来你说我打印的IPA硅谷应该出现在哪？在这了啊，你因为我们说了两个，无论按照哪一种策略，因为一个主题，无论按哪一种策略，一人一个吧，啊一人一个，当然你做测试的时候，可能第一个分配给他，这是有可能的啊，这个是有可能的啊OK，那这种情况是不是我们看到了，增加了一个消费者消费这个同一个组里边消费策略是不是变了呀。对吧，不是说你一个人消费两个分区了吧，一人一个分区了吧，那此时我是不是还可以再增加一个呀。

103，我再来一个。好，这个时候呢，他有多了一个警告。多了一个警告。没有给这个消费者。三个都有这个警告。三个都有这个形状，因为你重新分配了，有一个看什么多余的对吧，那我们看一下是哪一个啊，是不是我们所想的，是不是新进来的这个A到哪。到这个好bbb，哎，到这这个恰好是这样，那我们这样。因为有时候就测试这个效果就很烦啊，我再加一个行吧。我再加一个，是不是又又多了一个，因为这个东西，因为之前有时候一看这个新加入进来了，但是他呢，就没有他要报两个警告了，对吧。

哎，这款你也能看到默认的消费策略叫什么，其实我想找的就是这个参数叫什么吧，啊默认的啊，默认的是这种方式。好，然后再来打印一个什么CCC，我看在哪。又在这，我怎么测试不出来我要的效果呢？呃。那这个东西挺烦的啊。放弃吗？不是，我之前测的时候一次就成功了，但这次呃很烦，诶再加一对啊，这个两个的时候没有问题对吧？呃，然后其实你们自己在下面测能测出这个效果，如有时候课堂上他这个东西就很烦，就是你要演示它的时候，它还出不来。我就希望要的效果是什么，这出现无论是第一次出现出去，还是第二次出现，是不是你能证明它重新分配了呀，啊证明重新分配了，其实你看这个地方其实也能说明他这个类都给你打出来了，对吧，他说用这个类进行重新分配的时候，有一个东西不对吧，而且他打印到三个地方，不是只打印到这一个地方，说你没有东西消费版啊，其实可以证明这个问题了，但是呢，还是希望这个东西能看一下。

呃。算了，这个还真真有问题啊，我想想看，我想想看，我想想办法，这样我到103上去就行了。把第一个关了，那那就不是我们要的效果了，那你是第一个关了，那强制的那肯定会变嘛，我要的就是一二他们俩之前是不是绑定好了对吧，绑定好了，然后我要看一下它的一个重新分配的一个问题啊。如果说再不行的话，就大家自己去测一下这个东西肯定是可以的啊，肯定是可以的啊，看一下啊，不是VI一下，注意你要在103做测试的时候，你是不是应该把103这个地方也给他改个。

因为你不改的话。那不是它不是不同，不是同一个组嘛，对吧，艾特硅谷好诶把它103改成艾特硅谷104呢，我也来一个104呢，我不改组名也证明一下，发的时候只要你组不同，是不是可以同时消费证明一个这个事可以的啊CD奥利model卡不卡好这一块呢，我。来嗯，把它复制一份，其实104上面加不加他都无所谓吧。加了它，说明你用的是test。那个consumer group那个组对吧，我不加不加，让他来一个什么随机分配的，肯定不是一个组，对吧，把它起起来，然后我们再起一个103，上面起个103，如果说这次测不了，我也没办法，就是这个东西他有时候就很烦哦。要不也可以打开我上一个班讲课的视频，那个一次就成功啊，那个一次就成功。

好，我们再来输一条数据A。还是在这，还是在这儿，还是这个地方，这个地方能同时消费吧，因为它是属于什么不同组啊，不同组可以同时消费，这个没问题啊AB。啊，还是在这儿，还是在这啊还是在这，这个确实不太行，但是呢，其实我们能看到是他调用把这个类都给你列出来了吧，啊其实他做了重新分配啊，做了重新分配，只不过说每次恰好就分配到这个点上面，这就很烦啊，诶我可以做这个事啊，我先把它停掉。然后把他加进来。啊，把它加进来试试，现在呢A。它对吧，然后bbb应该在哪了呀。应该在它对吧，那我再把它提起来试一下。就现在用的是它们俩对吧，用的他们俩，我现在只要这个能接收到数据，是不是说明新加进来超过那个分区就重新分配了呀，对吧。

哎，是吧，哎，就之前做测试的时候，一次就成了，是不是说明他重新分配吧？啊就是想也是这个效果，因为之前两个分区是不是被你们俩一人一个分区消费了呀，你怎么发能学嘛，一人一个，一人一个，但是当我加了一个进来，加了一个进来之后，是不是超过了你分区数了三个大于2万啊，这个时候是不是要重新分配，因为只有这种情况我们才能看出来它重新分配的一个效果是不是。其实如果说一直还是他们俩消费，那你说重新消费，你说重新或者说没有重新分配，这不都一样吗。能理解这个事儿吧，啊，所以呢，为了就演示这个效果，那这个104是为了演示我们所说的什么不同组可以同时消费同一个分区吧，啊也就这个意思，要注意一下啊，注意一下这个点啊，所以呢，最后还好也示出来了是吧。要不然之前上课的时候真的就一次就成了，但这块就他重新分配之后还是这样。

可以写别的啊，对，还有一个问题啊，就是之前有同学提到了啊，就刚才这个同学提到，就是这个地方到底写102还是写什么的问题。写任何都可以，最好是写三个对，因为你想想看，如K怎么工作，它是一个集群，假如说他没请求到leader，请求到方路，你是写操作。Follow发给leader leader写完之后通知到所有的follow吧，所以你任何一台机器都行。还有一个问题就是我写的brook list这个东西到底写102、103、104也是一样的，因为它是以集群工作的，在哪都一样，它不像内no的。Name not只有一个吧，你得写那个啊，还有一个就是name not配了ha之后，你只能写那个什么。Service。你能具体的写102103吗？除非你知道谁是活着的，你确定一下102是active的，你可以直连102，这个可以，它允许你连，但是如果说102是stand 103是active，那你连102它会告诉你什么？

Stand没有什么读写权限，他会报这个错，那你要写的是service，相当于是这种集群工作的，你只要连到集群里面就行了，能懂这意思啊，所以说任选一个点就行了。但是在生产环境当中，我们写API的时候三个东西，因为你不知道将来你假如写写的102 102库了吗？假如说此时我把ZK102给它剃掉。是不是还能正常工作？三台挂一台是不能正常工作啊，对吧，但是你说你直接连101，这个时候能连上吗。这个时候就连不上了啊，这个时候连不上了，因为我们写命令行里边呢，更多的做测试，所以呢，我长期写的是102，就写一个就行了啊，最好在API里面，我们到时候能看到用逗号隔开写三个。

啊逗号隔开三个，因为他发现第一个挂的时候，他会去找103 103挂点他会找104啊一个一个去找啊一个去找是这样的啊。