【发布时间】：2014-03-02 01:34:15
【问题描述】：
我已经设置了一个 Kestrel 服务器，并且能够通过 python pykestrel 库设置和使用队列。
我们有一个场景，python 客户端写入 Kestrel 队列，Storm spout 需要从队列中读取。 我尝试使用storm-kestrel 库，但遇到了问题。谷歌搜索似乎表明它不支持 memcache 端口 (22133)。
我已经添加了 here 提供的 maven 绑定。没有使用 KestrelThriftSpout 喷口，而是使用 Kestrel.Client。编译没问题，但运行时出现 java.lang.NoClassDefFoundError 错误。
堆栈跟踪
1098 [main] ERROR org.apache.zookeeper.server.NIOServerCnxn - Thread Thread[main,5,main] died
java.lang.NoClassDefFoundError: Lnet/lag/kestrel/thrift/Kestrel$Client;
at java.lang.Class.getDeclaredFields0(Native Method)
at java.lang.Class.privateGetDeclaredFields(Class.java:2397)
at java.lang.Class.getDeclaredField(Class.java:1946)
at java.io.ObjectStreamClass.getDeclaredSUID(ObjectStreamClass.java:1659)
at java.io.ObjectStreamClass.access$700(ObjectStreamClass.java:72)
at java.io.ObjectStreamClass$2.run(ObjectStreamClass.java:480)
at java.io.ObjectStreamClass$2.run(ObjectStreamClass.java:468)
at java.security.AccessController.doPrivileged(Native Method)
at java.io.ObjectStreamClass.<init>(ObjectStreamClass.java:468)
at java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:365)
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1133)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347)
at backtype.storm.utils.Utils.serialize(Utils.java:52)
at backtype.storm.topology.TopologyBuilder.createTopology(TopologyBuilder.java:94)
at com.rr.storm.ArticleTolopolgy.main(ArticleTolopolgy.java:35)
Caused by: java.lang.ClassNotFoundException: net.lag.kestrel.thrift.Kestrel$Client
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
... 15 more
有人可以确认storm-kestrel是否可以在这种情况下使用吗？
如果没有，是否有另一个 kestrel 客户端库被推荐在 Storm spout 中用于从 kestrel 队列中读取数据？
【问题讨论】：
-
能否请您发布您收到的错误消息？
-
您是如何配置 Spout 以从 Kestrel 读取数据的？
-
我按照此处的说明将绑定添加到 maven：github.com/nathanmarz/storm-kestrel。它编译得很好，但在运行时会出现可怕的 Java NoClassDefFound 错误。我是 Storm 和 Java 的新手，所以故障排除很困难。
-
说真的，如果没有堆栈跟踪（合理的）和您的 Spout，我将无能为力
-
我会在我重新开始工作时添加这些内容。我假设您是说storm-kestrel 库适用于这种情况，这只是我这边的一个错误？谢谢凯龙星。
标签： apache-storm kestrel