水路を使用しているので、いくつかのログメッセージをrabbitmqに収集する必要があります。私はrabbitmqからメッセージを読み取るソース実装を見つけましたが、rabbitにメッセージを書き込むことができるシンクを見つけることができませんでした。だから自分で書くことを考えていました。logsandraのようなサンプル実装を見ると、それほど難しくはないはずだと思いました。
ただし、カスタムシンクの作成方法に関するドキュメントは見つかりませんでした。水路の瓶のMavenリポジトリ、またはカスタムシンクをデプロイする方法のセットアップ手順が見つかりませんでした。
誰かが彼の経験を共有できますか、それ以上に、既存のチュートリアルを教えてください。