首先我们先看一下kafka消费者流程,可以看到,我们需要创建一个consumeKafka_0_10 因为我们用的kafka的版本是0_10的对吧,要用对应版本的,消费者,然后,再用一个logattribute处理器,消费的
数据我们放到这个处理器里面进行查看
然后再就是需要配置consumekafka_0_10的,这个消费者处理器的
brokers这里的地址,还有topic,这个要和生产者放入数据的主题名字一样
然后groupId,组的话随意写一个就可以了
然后offset reset这里是latest从最新的数据开始消费
然后再看看logattribute处理器的设置,设置一下自连接,enabled启用就可以了
然后就是可以启动处理器,去查看日志了,当然要,先运行我们上一节,的生产者,然后再运行这里的
消费者