flume安裝的方法

這篇文章給大家分享的是有關flume安裝的方法的內容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

從官網下載

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中增加環境變量

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

都配置好后，就可以啟動了

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

在本機使用telnet進行測試

# telnet 192.168.1.10 22222
Trying 192.168.1.10...
Connected to 192.168.1.10.
Escape character is '^]'.
hello
OK

flume輸出如下信息表示啟動成功

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. }

感謝各位的閱讀！關于“flume安裝的方法”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！