【Flume】之 執行(案例一)
阿新 • • 發佈:2018-12-14
步驟
(1)配置檔案
- 在
/conf
下建立exmaple.conf
- 拷貝,配置
exmaple.conf
# example.conf: A single-node Flume configuration # Name the components on this agent a1.sources = r1 a1.sinks = k1 a1.channels = c1 # Describe/configure the source a1.sources.r1.type = netcat a1.sources.r1.bind = localhost a1.sources.r1.port = 44444 # Describe the sink a1.sinks.k1.type = logger # Use a channel which buffers events in memory a1.channels.c1.type = memory a1.channels.c1.capacity = 1000 a1.channels.c1.transactionCapacity = 100 # Bind the source and sink to the channel a1.sources.r1.channels = c1 a1.sinks.k1.channel = c1
(2)啟動Flume
./flume-ng agent -n a1 -c $FLUME_HOME/conf -f /data/soft/flume/apache-flume-1.8.0-bin/conf/exmaple.conf -Dflume.root.logger=INFO,console
這裡 $FLUME_HOME
就是 /data/soft/flume/apache-flume-1.8.0-bin
(3)使用telnet
進行測試
另起個終端,輸入:
telnet localhost 44444