news 2026/7/20 10:17:16

Flume1.11.0配置与简单使用(Java17环境)

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Flume1.11.0配置与简单使用(Java17环境)

Flume1.11.0默认Java8,如果系统环境为Java17,则额外需要配置Java8

前置条件:系统已经部署Java8和Java17,位置如下:

/usr/local/soft/jdk-17.0.1/

/usr/local/soft/jdk1.8.0_381/

一、上传解压

将apache-flume-1.11.0-bin.tar.gz软件包上传至/usr/local/soft文件夹下

cd /usr/local/soft tar -zxvf apache-flume-1.11.0-bin.tar.gz

二、添加系统环境变量

编辑环境变量

vi /etc/profile

添加如下内容

export FLUME_HOME=/usr/local/soft/apache-flume-1.11.0-bin export PATH=$PATH:$FLUME_HOME/bin

使环境变量生效

source /etc/profile

三、修改Flume环境变量

拷贝环境变量文件

cd /usr/local/soft/apache-flume-1.11.0-bin/conf/ cp flume-env.sh.template flume-env.sh

添加内容

export JAVA_HOME=/usr/local/soft/jdk1.8.0_381

编辑 flume-ng文件

vi /usr/local/soft/apache-flume-1.11.0-bin/bin/flume-ng

前面添加一下内容

JAVA_HOME=/usr/local/soft/jdk1.8.0_381 FLUME_JAVA_OPTS="-Xms512m -Xmx2048m"

四、配置文件

客户端(Source):收集信息

拷贝配置文件:

cp flume-conf.properties.template flume-client.properties

配置文件内容:

#分别指定agent的sources,sinks, channels的名称 名称可以自定义

#分别指定agent的sources,sinks, channels的名称 名称可以自定义 a1.sources = s1 a1.sinks = k1 a1.channels = c1 #配置目录scource a1.sources.s1.type =spooldir a1.sources.s1.spoolDir =/usr/local/data/logs/ a1.sources.s1.fileHeader= true a1.sources.s1.channels =c1 #配置sink a1.sinks.k1.type = logger a1.sinks.k1.channel = c1 #配置channel(内存做缓存) a1.channels.c1.type = memory

五、启动

cd /usr/local/soft/apache-flume-1.11.0-bin/conf/ flume-ng agent -n a1 -c conf -f flume-client.properties -Dflume.root.logger=DEBUG,console

其中:

-n:agent名称

-c:配置文件路径conf

-f:配置文件名称

如果还是有错,则直接指定JAVA_HOME

cd /usr/local/soft/apache-flume-1.11.0-bin/conf/ JAVA_HOME=/usr/local/soft/jdk1.8.0_381 FLUME_JAVA_OPTS="-Xms512m -Xmx2048m" /usr/local/soft/apache-flume-1.11.0-bin/bin/flume-ng agent -n a1 -c conf -f flume-client.properties -Dflume.root.logger=INFO,console

五、执行验证

将一个文本文件放入到/usr/local/data/logs/文件夹下,查看shell页面变化

附:集群拷贝

scp -r /usr/local/soft/apache-flume-1.11.0-bin root@hadoop101:/usr/local/soft scp -r /usr/local/soft/apache-flume-1.11.0-bin root@hadoop102:/usr/local/soft scp /etc/profile root@hadoop101:/etc/profile scp /etc/profile root@hadoop102:/etc/profile
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/7/20 10:17:06

TI Sitara PRU-ICSS增强型GPIO:多模式实时IO与硬件加速协议解析

1. 项目概述与核心价值在嵌入式实时控制领域,尤其是工业自动化、电机驱动和高速传感器接口等场景,对GPIO(通用输入输出)的性能要求早已超越了简单的“高电平/低电平”读写。传统的SoC主CPU GPIO,虽然功能完备&#xff…

作者头像 李华
网站建设 2026/7/20 10:16:13

I2C总线协议深度解析与AM263P微控制器实战应用

1. I2C总线协议深度解析:从两根线到复杂通信如果你在嵌入式领域摸爬滚打过,一定对I2C这个名字不陌生。它就像电路板上的“神经系统”,用最精简的两根线——SDA(数据线)和SCL(时钟线)&#xff0c…

作者头像 李华
网站建设 2026/7/20 10:14:41

持续学习中的Catastrophic Forgetting挑战与AI模型的缓解策略

持续学习中的Catastrophic Forgetting挑战与AI模型的缓解策略 在人工智能领域,持续学习(Continual Learning)是一个日益受到关注的研究方向。它指的是模型能够在不断接收新数据的过程中,持续优化自身性能,同时保留对先…

作者头像 李华
网站建设 2026/7/20 10:14:09

波司登转型成功:从保暖工具到时尚单品的品牌升级

1. 波司登的转型拐点解析羽绒服行业龙头波司登(3998.HK)在经历战略调整后,近年业绩呈现明显拐点特征。从2018年启动"聚焦主航道、收缩多元化"战略以来,公司营收从2018财年的88.8亿元增长至2023财年的162.1亿元&#xff…

作者头像 李华
网站建设 2026/7/20 10:13:52

C++与Java代码评审检查表实战:提升混合项目代码质量

1. 项目概述:为什么我们需要一份代码评审检查表?在软件开发的日常里,代码评审(Code Review)是保证代码质量、促进知识共享、统一团队规范的关键环节。但很多团队,尤其是混合了C和Java这类不同语言风格项目的…

作者头像 李华