我以前使用Kafka作为我的数据源，发现它非常强大，但有一个相当陡峭的学习曲线，设法让它部分工作，但有一些故障在这里和那里，并没有感到舒适的维持在生产中。所以决定切换到rabbitmq，因为我更熟悉它，但是我遇到了一个小问题。我无法从rabbitmq中找到apachestorm的clojure库。我应该扩展baserichspout还是有人能告诉我一个有用的图书馆。
dz6r00yl1#
没有明确的库来帮助实现这一点，所以我在java代码中扩展了“baserichspout”，编译成jar文件并将其导入clojure代码。因为我的storm集群运行的是backtype版本，也就是旧版本的storm，所以有相当多的欺骗行为。不过，这是我使用的示例代码。
1条答案
按热度按时间dz6r00yl1#
没有明确的库来帮助实现这一点，所以我在java代码中扩展了“baserichspout”，编译成jar文件并将其导入clojure代码。
因为我的storm集群运行的是backtype版本，也就是旧版本的storm，所以有相当多的欺骗行为。
不过，这是我使用的示例代码。