当前位置： 首页 > article >正文

NIFI大数据进阶_Kafka使用相关说明_实际操作Kafka消费者处理器_来消费kafka数据---大数据之Nifi工作笔记0037

article 2024/11/16 3:27:39

首先我们先看一下kafka消费者流程,可以看到,我们需要创建一个consumeKafka_0_10 因为我们用的kafka的版本是0_10的对吧,要用对应版本的,消费者,然后,再用一个logattribute处理器,消费的

数据我们放到这个处理器里面进行查看

 

然后再就是需要配置consumekafka_0_10的,这个消费者处理器的

brokers这里的地址,还有topic,这个要和生产者放入数据的主题名字一样

然后groupId,组的话随意写一个就可以了

然后offset reset这里是latest从最新的数据开始消费

然后再看看logattribute处理器的设置,设置一下自连接,enabled启用就可以了

 

然后就是可以启动处理器,去查看日志了,当然要,先运行我们上一节,的生产者,然后再运行这里的

消费者

 


http://www.kler.cn/a/7860.html

相关文章：

  • Mysql每日一题（行程与用户，困难※）
  • Android 项目依赖库无法找到的解决方案
  • 「QT」文件类 之 QDataStream 数据流类
  • 从0学习React（11）
  • 企业一站式管理系统odoo的研究——PLM插件的搭建
  • Vim 编辑器学习笔记
  • Vue3通透教程【九】父子组件通讯一目了然
  • 【从零开始学习 UVM】12.8、UVM RAL（续更） —— UVM RAL Model 实战项目（基于AXI总线的寄存器读写实例）
  • 从前M个字母中取N个的无重复排列 [2*+]
  • SQL VQ13 统计每天总刷题数
  • 基于价值认同的需求侧电能共享分布式交易策略（Matlab代码实现）
  • 大数据=SQL Boy,SQL Debug打破SQL Boy 的僵局
  • HTTP1.1、HTTP2和HTTP3是HTTP协议的三个版本——相同点和不同点
  • LinkedIn领英一、二、三度人脉分别代表什么意思？如何突破人脉限制开启领英社交化客户开发
  • 开心档之C++ 运算符
  • 【机器学习学习笔记】机器学习入门监督学习
  • Linux系统常用命令大全
  • 泡泡玛特“失速”，盲盒经济迎来拐点?
  • MySQL 查询常用操作(2) —— 条件查询 where
  • chatGPT的API一次多少钱-怎么用chatGPT解决问题
  • ​如何处理Xcode上传IPA文件后无法在后台架构版本中显示的问题？
  • 2023疫情当头，3个月转行软件测试拿下8k+offer，我心满意足了
  • C 输入 输出
  • 辉煌优配|A股上市银行拟合计派现超5300亿元 14家股息率在5%以上
  • Elasticsearch 8.X 如何基于用户指定 ID 顺序召回数据？
  • android framework-init进程