您好,登錄后才能下訂單哦!
這篇文章主要講解了“l(fā)oh4j整合flume的方法是什么”,文中的講解內(nèi)容簡(jiǎn)單清晰,易于學(xué)習(xí)與理解,下面請(qǐng)大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“l(fā)oh4j整合flume的方法是什么”吧!
一、配置啟動(dòng)flume
①flume的配置文件 conf/flume-conf.properties(這個(gè)文件一般是flume-conf.properties.default),復(fù)制修改后綴即可;
配置文件如下:
agent1.channels = ch2
agent1.sources = avro-source1
agent1.sinks = log-sink1
# 定義channel
agent1.channels.ch2.type = memory #mem channel
# 定義source
agent1.sources.avro-source1.channels = ch2
agent1.sources.avro-source1.type = avro #avro source
agent1.sources.avro-source1.bind = 0.0.0.0
agent1.sources.avro-source1.port = 41414
# 定義sink
agent1.sinks.log-sink1.channel = ch2
agent1.sinks.log-sink1.type = logger #logger sink
啟動(dòng)flume
bin/flume-ng agent --conf conf --conf-file conf/flume-conf.properties --name agent1 -Dflume.root.logger=INFO,console
二、log4j的配置
①在log4j.properties文件中添加flume appender
log4j.rootLogger=INFO,flume #日志級(jí)別,info和flume
log4j.appender.flume = org.apache.flume.clients.log4jappender.Log4jAppender
log4j.appender.flume.Hostname = 192.168.57.133 #flume地址
log4j.appender.flume.Port = 41414 #flume source監(jiān)聽的端口
log4j.appender.flume.UnsafeMode = true
log4j.appender.flume.layout=org.apache.log4j.PatternLayout
log4j.appender.flume.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss,SSS} [%t] [%c] [%p] - %m%n
三、測(cè)試
在maven中添加flume appender依賴
<dependency> <groupId>org.apache.flume.flume-ng-clients</groupId> <artifactId>flume-ng-log4jappender</artifactId> <version>1.6.0</version> </dependency>
編寫簡(jiǎn)單的測(cè)試類:
public class Log4jTest { Logger logger = LoggerFactory.getLogger(Log4jTest.class); /** * 測(cè)試flume * @Title: flumeTest * @Description: TODO * @param @throws Exception * @return void * @throws */ @Test public void flumeTest() throws Exception { while(true){ logger.info("spider", System.currentTimeMillis()); try { Thread.sleep(1000); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } }
運(yùn)行測(cè)試類,可以看到flume在控制臺(tái)的輸出
感謝各位的閱讀,以上就是“l(fā)oh4j整合flume的方法是什么”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對(duì)loh4j整合flume的方法是什么這一問題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云,小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。