跳至主要內容
Source组件

Flume的常用Source

Taildir Source

监听指定目录的多个文件(支持正则)

支持断点续传

agent-aisi.sources = source-aisi
agent-aisi.sinks = sink-aisi
agent-aisi.channels = channel-aisi

agent-aisi.sources.source-aisi.type = taildir
agent-aisi.sources.source-aisi.filegroups = f1
agent-aisi.sources.source-aisi.filegroups.f1 = /root/taildir/example.log
agent-aisi.sources.source-aisi.filegroups = f2
agent-aisi.sources.source-aisi.filegroups.f2 = /root/taildir1/.*log

# spacity the data where store  /root/taildir.json 
agent-aisi.sources.source-aisi.positionFile = /root/taildir.json 
agent-aisi.sources.source-aisi.filegroups.f1 = /root/taildir/example.log
agent-aisi.channels.channel-aisi.type = memory
agent-aisi.channels.channel-aisi.capacity = 10000
agent-aisi.channels.channel-aisi.transactionCapacity = 100

agent-aisi.sinks.sink-aisi.type = logger

agent-aisi.sources.source-aisi.channels = channel-aisi
agent-aisi.sinks.sink-aisi.channel = channel-aisi


shenjianZ...大约 2 分钟flumeflumesource