温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
好,上节课我们是采用的普通的异步发送,发送数据的时候啊,直接调用的是这个散的方法,就把数据发送出去了。那接下来呢,我们来讲一下叫带回调函数的一步发送。也就是发送完毕之后啊,他会给你来一个返回发送的结果。好,那接下来我们看一下怎么个带回调函数的义务发送双击。那之前我们在发送数据的时候,这个地方是一个散的方法。那现在呢,我们增加了一个派。那这个call back可以帮我们返回来发送数据的主题以及分区相关信息。那其实是从哪返回的呢?记住其实啊,这个数据发往的是这个地方。比如说先发往这个队列,然后队列就会给他返回,对应你要发送到哪一组题,你这个数据呢,是在哪一分区啊,是这个含义啊。行,那下面呢,我们就来实操一下。
01:01
那实操一下,我们还是基于上一个这个啊LC。这个呢,叫call back。How back,那我们看一下啊,其实这个呢是最难的了,对不对,哎,CV大法。呃,在企业里面啊,写代码的时候最容易出错的就是默认为以前写代码是对的,那这里面我们要仔细检查一下,首先呢,我们还是第一步创建一个啊卡普卡生产者之后呢,这里面配置相关信息,连接上卡普卡以及呢KV的一个设置。那接下来发送数据,那发送数据的时候发生不一样的地方。哪不一样呢,看这块儿。鼠标版的是1.ctrl加P。以前啊,我们只是采用了一个三的方法,哎,然后呢,New一个producer,那现在呢,我们需要增加一个copy back,那你需要增加,那就new一个。那这里面有一个返回函数,那我们判断一下啊,这里面有异常信息,以及呢啊返回的一些原数据信息,那E。
02:06
说exception,如果这个异常信息啊等于空,那就说明我们处理的正常返回对不对,正常返回,那正常返回,那就打印你正常的信息呗。比如说我们先打印一个叫主题。那主题在哪里呢?在这个meter data点。哎,就打印出来了,那我们再打印一个,打印一个什么呢?空号啊空格。分区。拼接上。原数据信息点分区。这样就OK了。哎,现在啊,我就可以发送完毕之后返回来,我这条数据发送到哪一个主题了,哪一个分区里面。那行,那下面我们来试验一下哈。好,右键执行。
03:00
看,哎,现在这边已经接收到数据了,同时在我控制台上,哎,已经有回调函数的打印了,比如说你这条数据发送到是for的主题,然后分区是一,那同学该说了,海哥,你这分区有012,为什么只发到一呢?哎,后续呢,我们再讲分区的时候再给大家详细去介绍哈。
我来说两句