使用 maven 部署 Storm 拓扑

Question

我有一个流处理管道，如下所示。

首先，我使用 Kafka 对消息进行排队。 接下来，我通过创建 Storm 拓扑来应用一些业务逻辑。 最后，我将数据流推送到 Elastic Search 中。

所有这些都捆绑到一个 Maven 项目中。构建 Maven 项目后，我必须手动将拓扑部署到 Storm 存储库。有没有办法自动化这个过程？意思是，我能否以这样一种方式创建/构建我的 Maven 项目：一旦构建 JAR，它就会将 JAR 连同拓扑定义类的名称一起上传到 Storm 存储库？

Answer 1

我不确定“上传到 Storm 存储库”是什么意思，但是，我猜 exec-maven-plugin 是你的朋友：http://www.mojohaus.org/exec-maven-plugin/

您可以在构建期间触发任意程序的执行。因此，您可以提供一个执行上传的 shell 脚本，并在组装 jar 后调用它。