版权说明:本文档由用户提供并上传,收益归属内容提供方,若内容存在侵权,请进行举报或认领
文档简介
Flume采集数据供KaFka消费学习目标Flume与Kafka配合消费数据132知识思政技能Flume与KaFka协调启动吃苦耐劳科学探索精神练习步骤启动ZooKeeper服务启动KaFka服务编写Flume脚本运行Flume脚本编写模拟发送数据的脚本模拟发送数据运行KaFka消费数据Zookeeper服务启动在三台计算机中启动Zookeeper服务,也可用脚本进行启动,为启动KaFka做准备,在测试环境中也可以使用KaFka自带的ZooKeeper启动服务。具体操作详见后面的视频。KaFka服务启动在三台计算机中启动KaFka服务,也可用脚本进行启动,但要注意的是KaFka关闭服务时要注意的事项。由于关闭脚本时找不到对应的id,无法关闭,进行修改Flume脚本的编写编写脚本时要注意,source设置为Channel要设置为,Sink要设置为kafka运行Flume脚本输入如下脚本命令,指定脚本的路径,将输出设置为编写模拟发送数据的脚本编写脚本模拟发送数据,利用Linux系统中的echo命令发送数据模拟发送数据在模拟发送数据之前修改文件运行权限命令如下模拟发送数据之前一定要先启动Flume脚本,因为只有发送没有接收,会提示出错。运行KaFka消费数据利用KaFka的消费者命令将数据输出至控制台运行KaFka消费数据安装地址:(1)官网首页:/(2)下载截图Zookeeper集群安装安装步骤:(1)集群规划,在hadoop01,hadoop02,hadoop03三个节点上都安装Zookeeper。(2)将apache-zookeeper-3.5.7-bin.tar.gz上传到linux的/opt/software目录下(2)在hadoop01中解压apache-flume-1.9.0-bin.tar.gz到/opt/module/目录下/具体命令:tar-zxvfapache-zookeeper-3.5.7-bin.tar.gz-C/opt/module/(3)修改apache-zookeeper-3.5.7-bin名称为zookeeper具体命令:mvapache-zookeeper-3.5.7-bin/zookeeper-3.5.7Zookeeper集群安装安装步骤:(4)配置服务器编号在/opt/module/zookeeper/这个目录下创建zkData具体命令:mkdirzkData在/opt/module/zookeeper/zkData目录下创建一个myid的文件用于标识Zookeeper服务器
具体命令:vimyid在文件中添加与服务器
对应的编号,每台服务器不能相同,用数字标识即可。(5)配置zoo.cfg文件重命名/opt/module/zookeeper-3.5.7/conf这个目录下的zoo_sample.cfg为zoo.cfgZookeeper集群安装安装步骤:打开zoo.cfg文件输入如下命令:vizoo.cfg修改数据存储路径配置dataDir=/opt/module/zookeeper/zkData增加如下配置#######################cluster##########################server.1=hadoop01:2888:3888server.2=hadoop02:2888:3888server.3=hadoop03:2888:3888(6)将文件Zookeeper文件发送至Hadoop02,Hadoop03中,具体命令如下:Zookeeper集群启动分别在Hadoop01,Hadoop02,Hadoop03中进入Zookeeper安装目录,并输入如下指令:bin/zkServer.shstart输入查看运行状态指令:bin/zkServer.shstatusZookeeper客户端命令行操作1)启动客户端bin/zkCli.sh-serverhadoop01:2181命令行语法命令基本语法功能描述lspath使用ls命令来查看当前znode的子节点[可监听]-w监听子节点变化-s附加次级信息create普通创建-s含有序列-e临时(重启
温馨提示
- 1. 本站所有资源如无特殊说明,都需要本地电脑安装OFFICE2007和PDF阅读器。图纸软件为CAD,CAXA,PROE,UG,SolidWorks等.压缩文件请下载最新的WinRAR软件解压。
- 2. 本站的文档不包含任何第三方提供的附件图纸等,如果需要附件,请联系上传者。文件的所有权益归上传用户所有。
- 3. 本站RAR压缩包中若带图纸,网页内容里面会有图纸预览,若没有图纸预览就没有图纸。
- 4. 未经权益所有人同意不得将文件中的内容挪作商业或盈利用途。
- 5. 人人文库网仅提供信息存储空间,仅对用户上传内容的表现方式做保护处理,对用户上传分享的文档内容本身不做任何修改或编辑,并不能对任何下载内容负责。
- 6. 下载文件中如有侵权或不适当内容,请与我们联系,我们立即纠正。
- 7. 本站不保证下载资源的准确性、安全性和完整性, 同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的伤害或损失。
最新文档
- 培训主管半年度绩效考核考评表
- 项目管理团队风险评估预案
- 娱乐主播内容制作与推广KPI考核表
- 助力心理成长共创阳光心态小学主题班会课件
- 信息系统安全演练备案函(6篇)
- 诚信伴我成长-小学主题班会课件
- 关于2026年5月客户退货处理流程的安排通知函3篇范本
- 设计优化绩效考核表
- 物流与供应链系统优化分析报告
- 小学主题班会课件:礼仪教育塑造未来
- GA/T 1215-2025中小学与幼儿园周边道路交通组织设计与交通设施设置规范
- 2026年四川省成都市中考语文真题(试题+答案)
- 2025年食品安全事故应急处置全流程培训
- 2026年淡水养殖高级水产工程师答辩题库
- 探秘南海IODP349基底玄武岩中钙质碳酸盐岩脉:岩石学与地球化学的深度剖析
- 上市公司收购方案
- GB/T 14233.2-2025医用输液、输血、注射器具检验方法第2部分:生物学试验方法
- 2025年基本公共卫生服务项目(慢阻肺健康管理)培训试题(附答案)
- 供应商资质与实力评估体系模板
- GB/T 4662-2025滚动轴承额定静载荷
- 路灯节能改造工程项目可行性研究报告
评论
0/150
提交评论