flume-ng源码浅析

1.架构   Source： 负责产生数据，将数据“传入”到channel，一旦写入channel成功，source就认为数据已经可靠的传输。   Sink：    sink不停的从属于自己的channel（此处有点类似于消息队列的消费者了）中获取数据，并且将数据写入到相应的后端中，如果数据写入失败则需要将相应的状况通知channel，让channel知道数据传输失败，下次获取时可以继续获取到这些

>>阅读原文<<