42_Kafka之与Flume对接（数据分类）

好，那么有一个问题，现在呢，因为前面采集过来的日志是不是分多种类型。对吧，那多种类型，我们是不是希望把它发到不同的。主题里边对吧，假如主题我取名字叫那个什么，点赞主题，评论主题，详情主题很多主题对吧，生产环境当中也一样，每一种是智的一个主题。啊，你这样给他区分开，最后你不同的业务线是不是直接从每个主题里面拿出去就过来，不能不用说再把主题里面数据过拿出来，再全部拿出来自己做过滤了啊，交给无线的数据就已经分类好了，那这个东西按照我们之前所学的可以怎么做，既然要分类，一定要用到什么。来器，而且是谁的个的来器做分类的。

做分类的对吧，啊的来电器做分类的啊，做分类的OK，那来电器怎么东西把这个数据给它分类的。是不是加一个头信息。对吧，在来器里边加个土信心，然后又结合着谁来用。选择器对不对。对吧，你可以把数据发到两个不同的China里边，那China一个China对应的。把这个C再复制一份，来个K2吧，来个K2好，如果说你是A主题的数据，那我就放到AB呢，就放到B，是不是这样的对吧，可以做吧，但是如果你用的是卡卡C这个东西呢，有一个很简单的方法，那个方法，刚才我说的那个方法大家会吗？应该没问题吧，就是把之前我们所做的那个，把两个数据me me给它映射，给它区分开的那种，把think换一下，换成卡夫卡think就行了吧，其他东西不用不用改。

能理解这个事儿吧，是那个案例。把最后的这以前我们写的不是log这嘛，打印的控制台的对吧，把两个数据给它区分开，我还记得是hello跟非hello的那种啊，对吧啊给它区分开，那现在呢，我们是用的是卡普卡single，我就可以不用这样的了啊，有一个简单的方式，也就是说我可以选一个China，我用一个China能做这个事。这个注意只有卡普卡think的时候才有，之前如果说你其他的think做不到这事，因为卡不卡think，它有一个比较特殊的点在于这个地方。卡不卡？Topic OK，来看一下，他说。这是一个topic，这个topic干什么用的？在卡当中的一个topic，对吧？为了确确保每一条消息将会被发送的一个地方，那我们肯定知道这个是这个意思吧，对吧？他写的卡卡逃，也就是说经过这个数据，经过到卡卡S数据会被发送到当前这个主题里边。

没问题吧，好，这个是默认的吧，他说了，如果说当前这个参数被配置了，这个消息将会被发送到当前这个位置，也就是说覆盖掉这个default什么topic。没问题吧，啊，它是覆盖掉，好，那接下来注意看一下这个问题。如果事件图当中包含一个topic字段。头，还记得当时我们说的是不是KB类型啊，如果它的K是topic。如果他的K是一个topic。那么，这个事件将会被发送到哪？发送到什么那一个主题对吧，覆盖掉什么当前配置在这的一个内容，也就是说这是kv value，你就要配一个什么。

主题的名字，假如说你配的是first，配的是什么second？注意这个时候你不能随便配sa。什么UA对吧，不能配这个了，你配的是一个什么主题的名字，能听懂啊，他自己根据这个图信息会决定当前这个数据发到哪，因为它这里面还有生产者代码这个东西呢，我们可以测一下，注意这个地方跟这些不一样了，这个你一定要写topic字段。之前我们是不是看到官方文档给的什么state案例里面我们自己写的是ta呀？对吧，这块你写太保他不认识，你必须写什么topic啊，我们来把这个东西来测一下，因为这个很关键，是有助于我们来把这个数据进行什么分类的，因为之前那种分类是不是你要写两个China。两个S吧，现在不用一个S一个参搞定这个事，来我们看一下，呃，那我们首先要有一个什么。

卡不卡的拦截器啊，不是是form的拦截器啊的拦截器点开我们之前是不是写了呀。点开Java拦截器对吧，类型拦截器，类型拦截器对吧，这个类型拦截器呢，我们现在做一个修改，只要修改一个地方。把这个地方改成。一定要改成逃避，改成逃避，然后这个我把它改成什么，2S可以吧，哎2ST这个呢，我们到s seco好，那我们捋一下，就是将来如果说这个数据啊，它包含哈。我们就把它放到first里边，如果不包含hello，我们就把它放到second里边，能懂这个意思对吧？好，那我们继续啊，CTRL做一个保存，然后这个地方改了之后要去干什么。打个包对吧，是芙蓉DEMO里边so口，诶打包之前呢，我们先听一下做安全起见是吧。

生长环境当中，这些你学的知识都要串起来用的啊，都要串起来用的，OK，那这个地方啊，Package，其实晚上如果时间有的多的话，你可以把我之前所讲的内容啊你用。类型，然后用China选择器去做分类，对吧，也可以吧，啊，只要把之前所说的multipla那个案例给他，把think改成考think就够。其他东西都不要动。不会被刚才说的那些东西都忘掉了吗？真忘掉了。就刚才说的那个案例啊，还记得吗？这个要是再忘了，真太过分了，不是这才学多久啊？讲过吗？谁问的谁问的，你敢站出来吗？到里边OK吧，啊，那为了安全起见，我们应该做个事情就是。

这样C给它干掉吧，这个我都给他停掉对吧？啊，这个也给它停掉啊，CD model这个里面我先把哪删掉，From杠应该是这个包叫什么名字。DEMO对吧，啊DEMO对，好DEMO把这个删掉吧，这样更保险一点，是不是好这个呢，进到目录下了，KW看一下在下吧，给他扔进来。好，那接下来我们是不是应该去写一个。配置配置文件对吧，好，然后CD胶布里边touch。什么内容啊，叫卡夫卡下划线。分类这样吧，叫table。下划线卡不卡点看可以吧啊，分类的卡卡分类的卡不卡啊，然后呢，我们还是同样的这个地方给他干什么。

打开分类的，嗯，在这那分类的卡卡，其实再把这个拿过来，然后在里边加什么东西就行。是不是增加一个拦截器就行了，对吧？啊增加一个拦截器啊，我们在这增加一个拦截器啊，在这注释。叫intercept。啊，CTRL保存好，那接下来我们要做的事情找那个来截器在这吧，CD的下这个拿一下配置吧，看一下二。把这个东西直接给他搂过来吧。往这一放，但是呢，这个A2改成A1 a1只有一个拦截器吧，类型拦截器之前呢，是build的，这个都不用改了啊，因为类名我刚才都没改啊，都没动啊，那加这个就行了，不用加那个什么麦，跟那个麦一点关系都没有。

Map呢，是select拆选择器里边要用的能听懂这块只要加拦截器，这个拦截器只是为了在头里边添加一些信息啊，添加一些做一个保存，然后接下来还是同样道理，这个时候呢，我又要多复制一个了，因为要提两个消费者了，是不是。对吧，第一个这是first对吧，我把它移复制。复制到这吧，还有一个是second对吧。启动好这块呢，C DOD module卡不卡到这来，Topic SE second。好两个消费者启动了，那这个东西我们留着提什么。骑from的对吧，这个呢，From NG叫A的杠c comes，杠f job底下有一个table，这个看杠N是不是ae。好，然后接下来是我们NC。Host是12345是吧，啊五四端口。

数据分带的不带哈的。对吧，干hello的应该打印到哪啊first注意呃，这个地方呢，我还是同样的那样去做啊，就是说因为哦它不是同时打印的，那就无所谓了，这样我们就可以直接测啊，那输一个hello叫不叫hello。好了。First吧，是不是在这出现了，这有吗？这点到什么打印机了是吗？没有吧，好，这没有，然后我们出一个不带hello的，那我he不带hello吧，走在哪出现了。Second吧，啊，这样就直接用think这块就能帮我们把这个东西干什么给他区分开了啊，就是如果你用的是卡S这个就可以，应该是点到打印机了，没连啊好，那这个呢，你你随便测就说，因为这个我们这个代码跟之前一样，保留的是包含hello不包含hello的，那如果生产环境当中，你就看包含具体的是哪个日志的字段嘛，还是一样的，对吧？啊，你可以把这个数据给它区分开啊，这样比较方便啊，比较方便好那这样什么AA啊。

那就是到哪啊，到这个地方吧，啊，也就不带hello的，那hello，呃，硅谷啊，那这个东西到哪啊。到这吧，啊到这块啊就这意思，那这样呢，就能把我们日志给它区分开啊，它自带的这个功能啊，自带这功能，我们把它给它停下。