flume自定義source

package  me;   import  java.nio.charset.Charset; import  java.util.HashMap; import  java.util.Random;   import  org.apache.flume.Context; import  org.apache.flume.EventDeliveryException; import  org.a

>>阅读原文<<