前言：接上一篇，我们总结了一下自定义Sink的流程，这次我们实现一个自己的Sink，将数据Sink到Mysql数据库中。我们还是使用 Flume...

前言：接上一篇，我们使用flume自带的logger有些bug，只能显示前16个字节。本文将介绍如何解决这个问题，并分析Logger Sink的...

前言：flume通过使用Interceptors（拦截器）实现修改和过滤事件的功能。举个栗子，一个网站每天产生海量数据，但是可能会有很多数据是不...

前言: 继上一篇从source到channel到sink实现了一整套的流程之后，我们这次学习一下Channel Selector与Sink Pr...

前言：为了呼应上篇文章总结部分提出的点。这一篇文章决定来个实战Demo。需求就是使用Spooling Directory Source监听一个文...

前言：本文是flume学习系列的开篇，主要介绍了flume的各种组件及相关配置。但是本篇文章并不打算从环境搭建开始，因为比较简单而且网上资料也很...

1 .背景 flume是由cloudera软件公司产出的可分布式日志收集系统，后与2009年被捐赠了apache软件基金会，为hadoop相关组...

Flume的下载方式： wget http://www.apache.org/dyn/closer.lua/flume/1.6.0/apache...