flume interceptor 设置host不生效
使用flume-ng传输日志信息，用均衡负载的方式将agent数据推送到collector，数据流向如图： 未了区分不同的agent发送的数据，我在collector的config文…
flume avro 程序报错
如题：flume 启动程序的conf文件为 agent1.sources=source1 agent1.sinks=sink1 agent1.channels=channel1 agent1.sources.source1.type=spooldir ag…
flume 往hdfs 里写失败
2016-04-03 14:50:21,897 (hdfs-k1-call-runner-17) [ERROR - org.apache.flume.sink.hdfs.AbstractHDFSWriter.hflushOrSync(AbstractHDFSWriter.java…
怎样解析通过Flume写入HDFS中的sequence file
log4j的日志通过flume收集到hdfs中，并在flume里配置了hdfs的sink, 其中fileType为SequenceFile。但不知道hdfs里sequencefile的record, key和value类…
请对logstash与flume做比较
看了一些文章，发现并没有直接拿logstash和flume来做全面比较的观点，相反，反而有拿flume和kafka做比较的，不知是否是我理解有误，我觉得flume在功…
flume-ng 使用 MySQL Sink
我准备使用apache flume 1.3 来处理日志的收集工作，日志的量不是很大，每天10个G左右， 我准备仅把WARN和ERROR级别的日志抽取出来保存，供后续分析使…
请教一下有没有flume和kafka的相关博客？
@FrankHui 你好，想跟你请教个问题： 我们打算用flume采集日志，然后把日志发送给kafka。最近再学习这块的知识，也看了你的kafka的相关博客感觉很不…
