如何为 Storm 提供实时输入答案

【问题标题】：how to give real time input to Storm如何为 Storm 提供实时输入
【发布时间】：2013-05-11 00:56:57
【问题描述】：

我正在尝试执行storm，实际上数据是从某个端口发出的，使用我正在监听的storm spout程序，（即）实现SerialPortEventListener 我收到错误

no rxtxSerial in java.library.path thrown while loading gnu.io.RXTXCommDriver
5399 [Thread-26] ERROR backtype.storm.util  - Async loop died!
java.lang.NoClassDefFoundError: Could not initialize class gnu.io.CommPortIdentifier
    at movingAverage.LightEventSpout.open(LightEventSpout.java:53)
    at backtype.storm.daemon.executor$fn__3985$fn__3997.invoke(executor.clj:460)
    at backtype.storm.util$async_loop$fn__465.invoke(util.clj:375)
    at clojure.lang.AFn.run(AFn.java:24)
    at java.lang.Thread.run(Thread.java:722)

【问题讨论】：

您可以分享代码 sn-p 您将拓扑提交到集群的位置吗？还有关于你的风暴版本的信息

标签： hadoop cassandra bigdata apache-storm

【解决方案1】：

您似乎未能在 jar 中捆绑所需的库。确保您的 CLASSPATH 设置正确以包含所需的库，以便将其包含在 jar 中。

【讨论】：

@G Gordon Worley III：我错过了一些要构建的罐子，现在我正在从外部端口获取数据。感谢您的回复..