如何編寫用於在hdfs接收器上創建avro文件的自定義flume-ng源代碼？

Question

我想寫一個可以在hdfs接收器上創建avro文件的CustomSource。但我無法弄清楚。

希望看到一些指導方針或示例。

Answer 1

這將幫助你瞭解詳細內容： https://flume.apache.org/FlumeUserGuide.html

但在高水平上創建自定義水槽來源： 1.更改水槽配置。在此添加源配置並將其指向MyCustomSource.java 2.在MyCustomSource.java中編寫源邏輯並將該jar複製到flume節點並重新啓動。