20_尚硅谷_Kafka_低级API之测试.avi原创

好，接下来我们做一个测试，那当然我这块就没有做那个。呃，什么保存，然后去获取，那你要是用办处来循环调用的话，它每次获取的一个值都完全一样的吧，都完全一样的，OK，那这个地方我们先用一个这个。Lower consumer，然后拿这个lower consumer来点get data吧。get data它里面要一些参数，首先是一个波斯，第二个是port。第三个是，然后还有那个part，然后。在的，哎，传进去啊，打印一个值，然后我们看一下。然后我们的集群啊，机器中午应该是关了，我开一下吧。103104现在看三个，嗯。好啊，这块呢，先看这个peopleable k star。

哦，CK，我之前没关是吧。啊，ZK没关，然后OT我们看一下它有没有有没有问题啊，嗯，Modelable b ZK solve.status status。他还没有没有挂掉对吧，旗下这个卡卡。卡夫卡，然后model卡夫卡。Con点这个粘下啊，发送到所有确定。然后我们再开一个这个窗口。再开一个窗口。卡布相当于已经启动了啊，这块呢，我们可以看一下。卡不卡啊，这个是什么，那个从K都有了吧，啊都有了之后，我们来跑一下我们这个当前的一个低级消费者的一个任务啊，低阶消费者的一个任务怎么下。

Second零号分区，从二开始消费对吧，从二开始消费。看一下consumer这块，它有一个。那个是刚才那个说方法已过时对吧。打印两条数据出来了，正常的，我们来看一下，用这个高级消费者。但是我们当时或者说这样，你看啊，啊，我们干一个什么事呢，生产者。这个地方有一个什么生产者吧，生产者我往当前我添加了这个什么。帕丁上的对吧，我们自定义的是不是往零号分区里面发送数据啊，我再插入几条。再插入几条，那又插入了至少十条，它这个opposite都到哪了。24了吧，24了，然后再拿什么。低级消费者来消费一下，知道我我在测什么吗？

还是两条吧。还是两条对。其实我要测的是什么，就是100那个数据对吧？啊100就这之前提过，我们乍一看特类型，以为它是条数，是不是，它其实不是的，它就不是的，那这块我们把它调调大一点，调大一点好再把它走一下。那边已经到了24了，对吧，24了OK。是不是24对吧，从哪开始的二一直到24，就所有数据都能消费到吧，所以说要注要要注意的一个点就是它类型是int，但其实它不是表示的是多少条数据啊，就是表示的是一个字节数，字节数是这样的啊，在里边的一个字节数，OK，而且那个节数是包含什么涛那个头，还有那些圆柱信息等等这些内容的啊，加在一块的，所以你能看到只有两条数据能出来，对吧？啊，只有两条数据。

然后数据应该是没有错的吧，就是整个的什么我们当时传的hello啊，然后0123456789都能解析成功的，都能够解析成功的，因为我们是模仿着源码里面来的，源码里面它也是将它转成了一个。子节数组，然后对这个直节数组进行六的一个spring啊，怎么看这块是有的，或者说你能够找到这个类看一下，嗯。反序列，反序列化，我们当时不是传了一个反序列化的一个这个东西进去嘛，对吧，你可以干什么呢？CTRLC在这CTR double shift就是按两项shift对吧，可以搜索。找一下这个嘞，因为他这个加班比较多。这么慢吗？现在ID现在都变得这么慢了。在这就是这个走进来啊，走进来这就是它的一个那个，刚才我们看到那个类啊，全类名就在这，它也是一样的，它传进来反序列化的时候呢，它也是抛一个加上一个字节数组，然后对自节数组进行什么。

六了一个string啊，六了一个string啊，其实就是啊，也先把它转成了一个字节数图，然后做那个反序列化的反切化出来啊，变成那个具体的一个string啊，具体的思维是这样的啊，它也是这样做的，所以说这块的一个东西，大家需要注意一下一个点就行了，然后更重要的这块就是它的一个逻辑啊，里边需要发送什么东西，发送什么东西那。之后在那个Spark的时候，大家能记得记得什么呢？记得simple consumer。第一个记得这个类，第二个基本的一个什么请求，这些东西大致的步骤有一个印象就行了。大的方向呢，第一个这个S这个类要记得，第二个就是先要获取A的。获取leader啊，然后呢，获取。因为你真正的做项目过程当中，你不可能像我这样，就是每次都从二开始，每次都能二开始吧，你要自己把奥赛的维护吧，就是获取赛，获取赛，然后就是获取数据吧，第三步获取数据。

啊，获取数据之后干什么。存off的要存进去吧，要不然下一次获取不没有意义吗？要存进去吧，要存进去就是跟我们什么之前写的那个my so source里边处理的一个逻辑是一模一样的，一模一样的，你完全可以模仿一下，模仿一下什么呢？这地方加一个GDPC的一个链接，将你的off存到MYL表里边。那这也是可以的，那就是一个数据offet，不就个浪型的数据嘛，对吧，浪型的数据你把它保存在哪都无所谓，都无所谓，整个的步骤呢，是获取leader啊，就是找leader，然后呢，获取off outside。然后根据这两个东西是不是生成那个什么SIM对象啊，对吧？哎，拿着这个东西，拿着leader去生成那个SIM对象，去真正的获取数据，那获取数据里边是不是又用到这个offet呀？哎，这个两个核心的东西就是为了我们这个symbol cons symbol对象啊，第一个要生成这个symbol对象，第二个offet是不是来。

At的时候用的呀，对吧，At的时候用的，那后面呢，就是说你把这个数据获取到了之后，因为你有一个什么message and offet这个对象吧，拿这个对象能获取到它的一个offet，然后将这个offet呢，保存到你想要保存的地方啊，想要保存的地方是这样的，那这个测试呢啊，我们也都测过了，然后主要的测了一下这个就是关于那个100的问题。啊，大家需要留个心眼就行了，留个心眼它不是指的是那个多少条数据啊，不是多少条数据是这样的。