apache flumeからsyslogにデータをシンクすることは可能ですか?私は現在公式のドキュメンテーションからチェックしていますが、Syslogへのシンクコネクタは存在しないようです。私はsyslogにソースとシンクの両方をサポートしているので、代わりにlogstashを使用しています。しかし、それが分散されておらず、スケーラビリティがないという欠点があります。apache flumeを使用してsyslogにデータをシンクする方法
ありがとうございます。
apache flumeからsyslogにデータをシンクすることは可能ですか?私は現在公式のドキュメンテーションからチェックしていますが、Syslogへのシンクコネクタは存在しないようです。私はsyslogにソースとシンクの両方をサポートしているので、代わりにlogstashを使用しています。しかし、それが分散されておらず、スケーラビリティがないという欠点があります。apache flumeを使用してsyslogにデータをシンクする方法
ありがとうございます。
Java用のSyslog APIを知っている場合は、Syslog用に独自のカスタムシンクを作成できます。 StackoverFlowでThisの質問がありましたら、あなたに手伝ってください。
カスタムシンクの作成については、あまり複雑ではありません。 AbstractSink
クラスを拡張し、Configurable
インターフェイスを実装する必要があります。これは基本的にそれぞれpublic Status process()
とpublic void configure(Context context)
メソッドをオーバーライドすることを意味します。