Skip to content

huangyueranbbc/FlumeDemo

Repository files navigation

#FLUME DEMO

MyApp.java:
flume-ng agent -c conf -f case_client.conf -n a1 -Dflume.root.logger=INFO,console

FailOverRPC.java LoadBalanceRPC.java
flume-ng agent -c conf -f case_client1.conf -n a1 -Dflume.root.logger=INFO,console
flume-ng agent -c conf -f case_client2.conf -n a1 -Dflume.root.logger=INFO,console
flume-ng agent -c conf -f case_client3.conf -n a1 -Dflume.root.logger=INFO,console

MySink.java
flume-ng agent -c conf -f case_custom_sink.conf -n a1 -Dflume.root.logger=INFO,console

MySource.java
flume-ng agent -c conf -f case_custom_source.conf -n a1 -Dflume.root.logger=INFO,console

About

Flume Custom Development Flume自定义开发 JAVA

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages