flume多路复用怎么写

这篇文章主要介绍"flume多路复用怎么写"，在日常操作中，相信很多人在flume多路复用怎么写问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"flume多路复用怎么写"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

一、编写目地
通过对flume组件的了解，除使用拦截器外，还可以对源码修改或自定义源。本次测试使用的是对源码修改。使用虚拟搭建flume + kafka环境，编写功能简单的多路复用，主要是用flume的exec收集数据源，放入到logger、hdfs、kafka队列。

二、编译环境说明
1、jdk版本：jdk1.7.0_80 注：根据pom.xml中要求flume-ng-1.6.0需要在jdk1.7中编译，使jdk1.8可能会存在问题
2、flume版本：flume-ng-1.6.0-cdh6.7.0
3、maven版本：apache-maven-3.3.9

三、Flume源码的修改
3、用maven编译flume-ng-1.6.0-cdh6.7.0源码
3.1、下载flume
cd /opt/sourcecode
wget http://archive.cloudera.com/cdh6/cdh/5/flume-ng-1.6.0-cdh6.7.0-src.tar.gz
tar -zxvf flume-ng-1.6.0-cdh6.7.0-src.tar.gz

3.2、修改源码：
cd /opt/sourcecode/flume-ng-1.6.0-cdh6.7.0/flume-ng-core/src/main/java/org/apache/flume/source
在ExecSource.java中增加如下代码：
vi ExecSource.java
// 创建map(注：在源码中336行增加)

1. 
   

2. 
   

3. true
   

4. always
   

5. warn
   

6. 
   

7. conjars
   

8. Conjars
   

9. http://conjars.org/repo
   

10. default
    

到此，关于"flume多路复用怎么写"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！