flume - Flume-ng null イベントのカスタム シンク

Question

Flume-ng のカスタム シンクを作成しようとしています。既存のシンクとドキュメントを見て、コーディングしました。ただし、イベントを受け取るはずの「process()」メソッドは常に null で終了します。私は Event event = channel.take(); をやっています。しかし、イベントはヌルです。イベントがまだチャネルにあるため、このメソッドが繰り返し呼び出されることがログに表示されます。

誰かが私を正しい方向に向けることができますか?

Answer 1

これは仕様によるものです。シンク ランナーはイベントを使用してシンクをポーリングするnullため、シンクが有効であり、将来のイベントを受け入れる準備ができていることを確認できます。nullイベントを受信したら、必ず を返しますStatus.BACKOFF。シンク プロセッサは、再試行する前に少し待機します。