flume對接kafka時延遲和高吞吐量以及flume篩選日誌

　如下是個人flume配置文件，實現了低延遲，篩選功能apache # 命名 a1.sources = r1 a1.sinks = k1 a1.channels = c1ui # sources配置 a1.sources.r1.type = exec a1.sources.r1.command = tail -F /root/flume.log a1.sources.r1.batchSize=1

>>阅读原文<<