4
flumeを使用しています。私はrabbitmqにいくつかのログメッセージを収集する必要があります。私はrabbitmqからメッセージを読み込むソースimplementationを見つけましたが、ウサギにメッセージを書き込めるシンクが見つかりませんでした。だから私は自分自身を書くことを考えていた。 logsandraのようなサンプル実装を見ると、それほど難しいとは思えませんでした。カスタムflume OGシンクの書き方
しかし、カスタムシンクの書き込み方法に関するドキュメントは見つかりませんでした。 私はflume jarのmaven repo、またはカスタムシンクを配備する方法の設定手順を見つけられませんでした。
誰でも自分の経験を共有したり、それ以上に既存のチュートリアルを指摘できますか？