标签:
文件大小:107M ,共490010条记录
(1)Source配置
Flume Source采用spooldir的方式,直接读取预先准备好的测试文件。
agent.sources.source1.type = spooldir
agent.sources.source1.spoolDir=/data/flume/dir
(2)MemoryChannel配置
agent.channels.memoryChannel.capacity = 1000000
agent.channels.memoryChannel.transactionCapacity = 1000000
agent.channels.memoryChannel.type=memory
(3)FileChannel配置
agent.channels.fileChannel.type = file
agent.channels.fileChannel.checkpointDir = /data/flume/checkpoint
agent.channels.fileChannel.dataDirs = /data/flume/data
(4)JVM配置
JAVA_OPTS="-Xms256m -Xmx256m -Xss256k -Xmn128m -XX:+UseParNewGC -XX:+UseConcMarkSweepGC -XX:-UseGCOverheadLimit"
Flume Config | Time(s) | Throughput(events/s) |
---|---|---|
MemoryChannel+FileSink | 51 | 9608 |
FileChannel+FileSink | 250 | 1960 |
Flume Config | Time(s) | Throughput(events/s) |
---|---|---|
KafkaSink+MemoryChannel | 57 | 8597 |
KafkaChannel | 50 | 9800 |
KafkaSink+FileChannel | 830 | 590 |
Flume Config | Time(s) | Throughput(events/s) |
---|---|---|
FileChannel+HdfsSink | 148 | 3311 |
标签:
原文地址:http://blog.csdn.net/lnho2015/article/details/51917030