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-class="lazy" data-src.tar.gz
tar -zxvf flume-ng-1.6.0-cdh6.7.0-class="lazy" data-src.tar.gz

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

1. <repository>
   

2.       <releases>
   

3.         <enabled>true</enabled>
   

4.         <updatePolicy>always</updatePolicy>
   

5.         <checksumPolicy>warn</checksumPolicy>
   

6.       </releases>
   

7.       <id>conjars</id>
   

8.       <name>Conjars</name>
   

9.       <url>http://conjars.org/repo</url>
   

10.       <layout>default</layout>
    

11.     </repository>

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