前回FLUME_CLASSPATHにしていしたディレクトリないのjarをコピーしてきてeclipseのビルドパスに通す。}headersにhoge=fugaが入っている事が分かる。補足sinkにgetTransactionというメソッドがあるが、transactionはchannnelに実装されていて、sinkがデータを取り出してから失敗した場合に、transaction.rollback()を呼ぶ事で、ロールバックされるようになっている。processメソッドで、Statusを返すようになっているが、BACKOFFステータースを返すと、runnerがポーリングでwaitを入れるようになる。繰り返しBACKOFFを返すと、一定時間まで少しずつwaitが入る時間がのびるようだ。メモ音声認識リモコン作ってみたwebsocketの処理の仕方を考えてみた。えーちゃんwebsocketの処理の仕方を考えてみた。