前言:接上一篇,我们总结了一下自定义Sink的流程,这次我们实现一个自己的Sink,将数据Sink到Mysql数据...[作者空间]
前言:接上一篇,我们使用flume自带的logger有些bug,只能显示前16个字节。本文将介绍如何解决这个问题,...[作者空间]
前言:flume通过使用Interceptors(拦截器)实现修改和过滤事件的功能。举个栗子,一个网站每天产生海量...[作者空间]
前言: 继上一篇从source到channel到sink实现了一整套的流程之后,我们这次学习一下Channel S...[作者空间]
前言:为了呼应上篇文章总结部分提出的点。这一篇文章决定来个实战Demo。需求就是使用Spooling Direct...[作者空间]
前言:本文是flume学习系列的开篇,主要介绍了flume的各种组件及相关配置。但是本篇文章并不打算从环境搭建开始...[作者空间]
概述 虽然在上一篇博文《flume - 启动过程分析(1)》我们已经了解了flume相关组件的配置的加载以及启动...[作者空间]
概述 这个文章是flume源码系列的开门篇,也是本人第一次阅读flume相关的代码,文章会参考一些已有的文章并结...[作者空间]
Flume的下载方式: wget http://www.apache.org/dyn/closer.lua/flu...[作者空间]
1 .背景 flume是由cloudera软件公司产出的可分布式日志收集系统,后与2009年被捐赠了apache软...[作者空间]