maxBackoff 4000 The maximum time (in millis) to wait between consecutive
attempts to write to the channel(s) if the channel is full. The source will start at a
low backoff and increase it exponentially each time the channel throws a
ChannelException, upto the value specified by this parameter.
batchSize 100 Granularity at which to batch transfer to the channel
inputCharset UTF-8 读取文件时使用的编码。
decodeErrorPolicy FAIL 当在输入文件中发现无法处理的字符编码时如何处
理。FAIL:抛出一个异常而无法 解析该文件。REPLACE:用“替换字符”字符,通常是
Unicode的U + FFFD更换不可解析角色。 忽略:掉落的不可解析的字符序列。
deserializer LINE 声明用来将文件解析为事件的解析器。默认一行为一个事件。处
理类必须实现EventDeserializer.Builder接口。
deserializer.* Varies per event deserializer.
bufferMaxLines – (Obselete) This option is now ignored.
bufferMaxLineLength 5000 (Deprecated) Maximum length of a line in the commit
buffer. Use deserializer.maxLineLength instead.
selector.type replicatingreplicating or multiplexing
selector.* Depends on the selector.type value
interceptors – Space-separated list of interceptors
a1.sources.r1.type = spooldir
a1.sources.r1.spoolDir = /home/park/work/apache-flume-1.6.0-bin/mydata
a1.sinks.k1.type = logger
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100
a1.sources.r1.channels = c1
./flume-ng agent --conf ../conf --conf-file ../conf/template4.conf --name a1 -