我有一个现有的 Avro RPC 客户端，可以将数据发送到 Avro RPC 服务器。Avro RPC 服务器当前将数据写入 HDFS（并且还执行其他操作）。我们正在将我们的服务器进程更改为基于 Storm。我希望找到一种简单的方法将我的数据导入 Storm，希望使用我现在拥有的 Avro RPC 消息。
我一直在寻找一种方法来做到这一点，到目前为止没有成功。Storm 有一个 RPC 模型，但它似乎仅限于传递字符串，这是我想避免的（为什么我首先去了 Avro）。Zeromq 可能是一种可能性，但对于我想要做的事情似乎有限。
有人可以为我建议一种优雅的方式来让我的 Avro RPC（基于模式的数据）进入 Storm 吗？
谢谢！！！！