热门
Flume首先会从数据源接受数据到Source,然后Source将数据封装成事件,然后交给Channel Processor,再把它传递给拦截器链,这里拦截器可以有多个,为了解耦,但是来说还是一个拦截器链比较快,再拦截器部会封装头部信息,然后将处理好的信息交给Channel选择器,就是复制和多路复用,控制Source的数据发往哪个Channel,然后将按照Channel的配置策略将事件发往指定Channel,之后经过Sink组,他是做轮询和负载均衡这些。