シンプルなマルチスレッドのFlumeソースが必要

Question

単純なマルチスレッドのFlumeソースをセットアップする方法についてのアドバイスを探しています。

Reading Flume spoolDir in parallel

我々は持っている：

常に単一スレッドになります私は私のインターセプタをテストするために私の地元のdevの環境でspoolDirソースを使用してきたが、以下のリンクから、それはspoolDir源のように見えますインターセプターは、スレッドセーフではないスレッドSimpleDateFormatterを使用しているため、バグの可能性があります。私は単純な開発環境で再現しようとしています。

Answer 1

私は最終的に私のdev環境をspoolDirソースからsyslogtcpソースに切り替えることで、私たちが本番で見ていたマルチスレッドバグの振る舞いを再現することができました。このバグは、私たちが期待していたものではなく、SimpleDateFormatterとは何の関係もなく、イベントヘッダーに追加情報を挿入する方法でした。

私は、syslogサーバにデータを送るためにnc（netcat）を使ってsyslogサーバをシミュレートしました。スレッド名とIDを記録することで、インターセプタが複数のスレッドから呼び出されていることを確認しました。

興味のある方は、おそらくspoolDirソースではなくsyslogtcpのようなマルチスレッドソースを使用してインターセプタをテストすることをお勧めします。