AvroRPCサーバーにデータを送信する既存のAvroRPCクライアントがあります。Avro RPCサーバーは現在、データをHDFSに書き込みます（他のことも行います）。サーバープロセスをStormに基づくように変更しています。できれば現在のAvroRPCメッセージを使用して、データをStormに取り込む簡単な方法を見つけたいと思っています。
私はこれを行う方法を探していましたが、これまでのところ成功していません。StormにはRPCモデルがありますが、文字列の受け渡しに限定されているようです。これは避けたいと思います（そもそもなぜAvroに行ったのか）。Zeromqは可能性があるかもしれませんが、私がやろうとしていることには限界があるようです。
スキーマベースのデータであるAvroRPCをStormに取り込むためのエレガントな方法を誰かが提案できますか？
ありがとう！！！！