flume-ng自定義插件部署

插件寫好以後打包上傳,將開發的jar包加入到flume中
方法一 :
進入vi /etc/profile 在文件中加入 exportFLUME_CLASSPATH = XXX/XX/XXX.jar
在CALSSPATH 的尾部加入:$FLUME_CLASSPATH , 而後保存退出後,在命令行執行sh/etc/profile ,經過在命令行輸入 flumeclasspath 查看插件jar包是否在其中,在其中表示配置完成(注:開發插件時引入的jar包必須都可以在flume classpath下找到,若是找不到的話像加入插件包的方式加入)web

方法二:
簡單的方法是將開發的jar包和須要引入的jar包直接複製到/usr/lib/flume/lib
修改flume-site.xml文件以下所示:
<property>
<name>flume.plugin.classes</name>  
<value>插件類得全路徑名(如:hello.HelloWorldSink) </value>
    <description>Comma separated list of plugin classes</description>
  </property>

將flume-site.xml文件放到master 和collector的/etc/flume/conf 下
啓動集羣配置便可spa

相關文章
相關標籤/搜索