这里就简单贴个配置吧，有问题欢迎留言探讨
sink的配置
##############################define [sink] begin###############################define the sink k1a1.sinks.k1.type=hdfsa1.sinks.k1.channel=c1a1.sinks.k1.hdfs.useLocalTimeStamp=truea1.sinks.k1.hdfs.path=hdfs://192.168.11.177:9000/flume/events/%Y/%m/%da1.sinks.k1.hdfs.filePrefix=cmcc-%Ha1.sinks.k1.hdfs.fileType=DataStreama1.sinks.k1.hdfs.minBlockReplicas=1a1.sinks.k1.hdfs.rollInterval=3600a1.sinks.k1.hdfs.rollSize=0a1.sinks.k1.hdfs.rollCount=0a1.sinks.k1.hdfs.idleTimeout=0#define the sink k2a1.sinks.k2.channel=c2a1.sinks.k2.type=com.cmcc.chiwei.kafka.CmccKafkaSinka1.sinks.k2.metadata.broker.list=192.168.11.174:9092,192.168.11.175:9092,192.168.11.196:9092a1.sinks.k2.partition.key=0a1.sinks.k2.partitioner.class=com.cmcc.chiwei.kafka.CmccPartitiona1.sinks.k2.serializer.class=kafka.serializer.StringEncodera1.sinks.k2.request.required.acks=0a1.sinks.k2.cmcc.encoding=UTF-8a1.sinks.k2.cmcc.topic.name=cmcca1.sinks.k2.producer.type=asynca1.sinks.k2.batchSize=100##############################define [sink] end##############################这里的是将同样的数据无差异sink到多个输出端，所以通道是复制模式
a1.sources.r1.selector.type=replicating一个是kafka，为了提高性能，用内存通道，一个到hdfs，离线分析，用文件通道
##############################define [channel] begin###############################define the channel c1a1.channels.c1.type=filea1.channels.c1.checkpointDir=/home/flume/flumeCheckpointa1.channels.c1.dataDirs=/home/flume/flumeData,/home/flume/flumeDataExta1.channels.c1.capacity=2000000a1.channels.c1.transactionCapacity=100#define the channel c2a1.channels.c2.type=memorya1.channels.c2.capacity=2000000a1.channels.c2.transactionCapacity=100##############################define [channel] end##############################以上就是无差异数据输出多个sink的配置，如果你想不同数据到不同的sink，需要用到通道的多路复用模式，，请参考【通道的多路复用】
片的时光如浮云般流过，我们的青春单薄的穿梭在蓝天之上。
