本文共 1172 字,大约阅读时间需要 3 分钟。
例子:a1.sources = s1a1.channels=c1a1.sinks=k1#tcp协议a1.sources.s1.type = syslogtcpa1.sources.s1.port= 5140a1.sources.s1.host= wangfutaia1.sources.s1.channels = c1a1.channels = c1a1.channels.c1.type = SPILLABLEMEMORY a1.channels.c1.memoryCapacity = 10000 a1.channels.c1.overflowCapacity = 1000000 a1.channels.c1.byteCapacity = 800000 a1.channels.c1.checkpointDir =/home/wangfutai/a/flume/checkPointa1.channels.c1.dataDirs = /home/wangfutai/a/flume/data#必须写a1.sinks = k1a1.sinks.k1.type = hdfs a1.sinks.k1.channel = c1a1.sinks.k1.hdfs.path =/user/wangfutai/flume/%y_%m_%d/%H_%M_%S #文件的名称a1.sinks.k1.hdfs.filePrefix = wangfutai- a1.sinks.k1.hdfs.fileSuffix=.flua1.sinks.k1.hdfs.inUsePrefix =inUse-a1.sinks.k1.hdfs.inUseSuffix =.t#目录回滚开启后每10分钟回滚一次a1.sinks.k1.hdfs.round = true a1.sinks.k1.hdfs.roundValue = 10 a1.sinks.k1.hdfs.roundUnit = minute#日志回滚#定时回滚 收集的文件 每隔60s生成一个文本#配置滚动生成a1.sinks.k1.hdfs.rollInterval = 60a1.sinks.k1.hdfs.rollSize = 0a1.sinks.k1.hdfs.rollCount = 0a1.sinks.k1.hdfs.idleTimeout = 0#输出格式a1.sinks.k1.hdfs.fileType = DataStreama1.sinks.k1.hdfs.writeFormat = Text#指定timeZonea1.sinks.k1.hdfs.useLocalTimeStamp = truea1.sinks.k1.hdfs.timeZone = Asia/Shanghai
转载地址:http://lgjxi.baihongyu.com/