如何在版本1.3.1中編寫水槽定製接收器和源碼

我正在嘗試在水槽版本1.3中編寫我自己的接收器和源代碼。它沒有配置文件flume-site.xml。編譯我的java文件後，如何使用這個自定義接收器？如何在版本1.3.1中編寫水槽定製接收器和源碼

2013-01-14 Shuo

您需要將您的編譯接收器放在水槽CLASSPATH的某處。在1.3.1版本中，簡單的lib /應該足夠了。對於較新的版本，您可以選擇使用「plugins.d」目錄，查看FLUME-1735 [1]以獲取更多詳細信息（固定在主幹中，並將成爲1.4.0的一部分）。

要配置flume實際使用接收器，請在配置中使用您的類的完全限定名稱（例如package.ClassName）。例如，如果你的類是在包「earth.europe」和類名是「WorldSink」，那麼你就需要使用以下配置片段：

a1.sinks = s1 
a1.sinks.s1.type = earth.europe.WorldSink

Jarcec

鏈接：

2013-01-16 10:28:28

回答