切记,在进行flume监测文件时采用的是正则表达式
2021-01-19 11:12
标签:tin 默认 oop ati json span this pos ado # Name the components on this agent #将数据流复制给所有channel #source #此处若只写.log那么肯定不行啊,这样就只监测文件名称为.log的文件而不是后缀为.log的文件,若想监测后缀为.log的文件那么采用上边标红的正则表达式,小伙子,去练练正则也可以哈 #channel a1.channels.c1.type = memory a1.channels.c2.type = memory a1.sinks.k2.type = avro # Bind the source and sink to the channel 切记,在进行flume监测文件时采用的是正则表达式 标签:tin 默认 oop ati json span this pos ado 原文地址:https://www.cnblogs.com/zlshtml/p/13336345.html
a1.sources = r1
a1.channels = c1 c2
a1.sinks = k1 k2
#下边这句是默认的,不配置也可以
#a1.sources.r1.selector.type = replicating
a1.sources.r1.type = TAILDIR
a1.sources.r1.positionFile = /opt/module/flume/taildir_position.json
a1.sources.r1.filegroups = f1
a1.sources.r1.filegroups.f1 = /opt/module/flume/test/.\*.log
a1.channels.c1.capacity = 10000
a1.channels.c1.transactionCapacity = 10000
a1.channels.c2.capacity = 10000
a1.channels.c2.transactionCapacity = 10000
#sink
a1.sinks.k1.type = avro
a1.sinks.k1.hostname = hadoop103
a1.sinks.k1.port = 4141
a1.sinks.k2.hostname = hadoop104
a1.sinks.k2.port = 4142
a1.sources.r1.channels = c1 c2
a1.sinks.k1.channel = c1
a1.sinks.k2.channel = c2
下一篇:5.MVCC
文章标题:切记,在进行flume监测文件时采用的是正则表达式
文章链接:http://soscw.com/index.php/essay/44050.html