flume - バージョン1.3.1でflumeカスタムシンクとソースを作成する方法

Question

flumeバージョン1.3で独自のシンクとソースを作成しようとしています。設定ファイルflume-site.xmlがありません。Javaファイルをコンパイルした後、このカスタムシンクをどのように使用できますか？

Answer 1

Flume CLASSPATH のどこかに、コンパイル済みのシンクを含む jar を配置する必要があります。バージョン 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

ヤルセック

リンク:

1: https://issues.apache.org/jira/browse/FLUME-1735