[TOC] # 流程  # 代碼 1. 先在flume的conf目錄下新建一個文件 ~~~ vim netcat-logger.conf ~~~ ~~~ # 定義這個agent中各組件的名字 a1.sources = r1 a1.sinks = k1 a1.channels = c1 # 描述和配置source組件：r1 # netcat類型,可以監控對應端口是否有數據 a1.sources.r1.type = netcat # 綁定到master這臺電腦 a1.sources.r1.bind = master # 監聽的端口,r1就是上面定義的 a1.sources.r1.port = 44444 # 描述和配置sink組件：k1 # 產生的數據顯示到控制臺 a1.sinks.k1.type = logger # 描述和配置channel組件，此處使用是內存緩存的方式 a1.channels.c1.type = memory # 內存容量,多少個事件 a1.channels.c1.capacity = 1000 # 事務容量,每個事務通道從源或提供給接收器的最大事件數 a1.channels.c1.transactionCapacity = 100 # 描述和配置source channel sink之間的連接關系 a1.sources.r1.channels = c1 a1.sinks.k1.channel = c1 ~~~ 2. 啟動agent去采集數據 ~~~ flume-ng agent -c conf -f /root/flume/conf/netcat-logger.conf -n a1 -Dflume.root.logger=INFO,console ~~~ ~~~ -c conf 指定flume自身的配置文件所在目錄 -f conf/netcat-logger.conf 指定我們所描述的采集方案 -n a1 指定我們這個agent的名字 ~~~ # 測試 先要往agent采集監聽的端口上發送數據，讓agent有數據可采 隨便在一個能跟agent節點聯網的機器上 ~~~ telnet anget-hostname port（telnet master 44444） ~~~