00:00
好,上节课我们是成功的,在卡法当中创建了一个first的主题,那你在这里面创建了一个first主题。那接下来我们就要创建一个卡法的生产者,向这里面发送数据,好,那创建生产者应该是用哪个脚本呢?遍布录下,哎,双击回车,你双击回车之后,你会看到,诶哪一个呢这个。是吧,哎,针对的是卡卡生产者电子脚本。好不好,很臭。好producer,那这个脚本怎么用呢?直接打回车。你会发现这里面仍然给你提供了大量的这个参数,那看一看啊,现在呢,我们是卡瓦生产者,要把这个数据啊发送到对应的博客端。那你想你要发送给博端,那你是不是得连接上对应的这个博。那好,那连接上的话,就用这个杠杠BOO连上。那你连上之后这个主,这里面有N多个主题,你要发往哪一个主题呢。
01:04
那你是不是得指定一下topic,好,那下面这里有一个叫杠杠topic。那这两个参数连上集群,然后向这个集群的某一个topic发送数据就可以了,那下面我们就来实际操作一下。尴尬。不。还是一样,不一样。1029092,首先连接上,然后呢把数据发到topic。里面走。你看这里面就提示有一个监控块,然后你就可以输入数据往里面去发了,比如说我们先输入第一个。哈,那这个哈,我们把这个数据发送到哪了呢?相当于是生产者把数据发送到集群当中,For的主题。那么如何来查看这个数据有没有发生到这个基金当中呢?我们需要怎么办?哎,需要创建一个消费者。
02:00
来消费这里面数据不就完了吗?好,那我们就来创建一个消费者啊,来到103。卡不卡?很臭。很臭。小妹。那这个脚本怎么用,直接打回车。打回家之后,这里面给你提示了大量这个参数,那这个消费者应该怎么用呢?仍然是这样道理哈,首先你得连接上对应的这个集群,你看你这博客,这消费者。哎,这生产者你要连接上它,连接上它之后,你是不得消费它哪一个主题啊,因为这里面有N多个主题,你得指定对应的topic啊,那指定topic在这呢。指定topic,那这样就可以进行消费了,那我们来试一下啊。比如说。他啊,然后呢,杠杠,What。是吧?SERVER1029092 OK,我要消费的是topic。
03:00
走。说海哥你这没消费到数据啊,哎,那是不是这个哈,不好使啊,给我来一个好使的艾特硅谷走。哎,你发现诶艾特五比这个哈罗还厉害对不对,哎,直接就把数据发送过来了,那再来一条,再来S。是不是也可以了,我再试试哈呢。你发现是不是哈也可以啊,哎,其实是这样的啊啊,正常情况下,你这个卡帕集群先搭建完毕之后,那我消费者启动之后,我会增量的去消费这里的数据,于是你后来的从生产者再发送过来数据,我能够消费得到那历史的数据。也就是说以前发生的数据我能不能读取到呢?那下面我们这儿。把它停掉。停掉之后加上一个参数杠杠。From。递给你走。呃,这个参数。
04:00
在里面把它拿过来啊,杠杠,From beginning。我加上这个参数之后,你会发现,诶,立即之前的历史数据,哈哈,At at你看。都已经打出来了啊,这个意思呢,加上杠杠from给这个参数的意思就是把你这个卡瓦基尼当中历史的数据,我也都一并的消费过来。那这个在生产环境当中会不会用呢?这也要分情况啊,呃,一般情况下呢,比如说我这个神经包启动之后,哎,我会增量的去消费,这里面产生数据,比如你后来的数据我都进行消费。那么如果加上刚化符号符给啊,有一些场景是不适用的,比如说这里面有可能保存的是七天的数据,那七天数据你这个肯性一加载之后,上来就把七天前的数据全都加载过来。那容易导致啊,后面这块呢,处理不及时啊,还有一些呢,这七天以前的数据有可能已经过时了,我这边已经没有必要进行一个处理了。
05:03
所以这个呢,要根据情况而定,要不要加杠杠方给你啊。
我来说两句