這篇文章給大家分享的是有關(guān)flume安裝的方法的內(nèi)容。小編覺得挺實(shí)用的,因此分享給大家做個(gè)參考,一起跟隨小編過來看看吧。
創(chuàng)新互聯(lián)建站專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù),包含不限于做網(wǎng)站、成都做網(wǎng)站、柴桑網(wǎng)絡(luò)推廣、微信小程序開發(fā)、柴桑網(wǎng)絡(luò)營銷、柴桑企業(yè)策劃、柴桑品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營等,從售前售中售后,我們都將竭誠為您服務(wù),您的肯定,是我們最大的嘉獎(jiǎng);創(chuàng)新互聯(lián)建站為所有大學(xué)生創(chuàng)業(yè)者提供柴桑建站搭建服務(wù),24小時(shí)服務(wù)熱線:18982081108,官方網(wǎng)址:www.cdcxhl.com
從官網(wǎng)下載
wget http://archive.apache.org/dist/flume/1.7.0/apache-flume-1.7.0-bin.tar.gz
解壓到/opt/flume目錄,并重命名
tar -zxvf apache-flume-1.7.0-bin.tar.gz -C /opt/flume cd /opt/flume mv apache-flume-1.7.0-bin/ apache-flume-1.7.0
在/etc/profile中增加環(huán)境變量
export FLUME_HOME=/opt/flume/apache-flume-1.7.0 export PATH=$PATH:$FLUME_HOME/bin
配置flume-env.sh
cd /opt/flume/apache-flume-1.7.0/conf cp flume-env.sh.template flume-env.sh
在flume-env.sh中配置
export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.272.b10-1.el7_9.x86_64/jre export JAVA_OPTS="-Xms100m -Xmx2000m -Dcom.sun.management.jmxremote"
配置flume-conf.properties
cd /opt/flume/apache-flume-1.7.0/conf cp flume-conf.properties.template flume-conf.properties
在flume-conf.properties配置
a1.sources = r1 a1.channels = c1 a1.sinks = k1 a1.sources.r1.type = netcat a1.sources.r1.bind = 192.168.1.10 a1.sources.r1.port = 22222 a1.sources.r1.channels = c1 a1.sinks.k1.type = logger a1.sinks.k1.channel = c1 a1.channels.c1.type = memory a1.channels.c1.capacity = 1000 a1.channels.c1.transcationCapacity = 100
都配置好后,就可以啟動(dòng)了
cd /opt/flume/apache-flume-1.7.0/ ./bin/flume-ng agent --conf ./conf --conf-file ./conf/flume-conf.properties --name a1 -Dflume.root.logger=INFO,console
在本機(jī)使用telnet進(jìn)行測(cè)試
# telnet 192.168.1.10 22222 Trying 192.168.1.10... Connected to 192.168.1.10. Escape character is '^]'. hello OK
flume輸出如下信息表示啟動(dòng)成功
2021-05-19 13:54:58,933 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO - org.apache.flume.sink.LoggerSink.process(LoggerSink.java:95)] Event: { headers:{} body: 68 65 6C 6C 6F 0D hello. }
感謝各位的閱讀!關(guān)于“flume安裝的方法”這篇文章就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,讓大家可以學(xué)到更多知識(shí),如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到吧!