風暴拓撲部署使用maven

Question

我有一個流處理的流水線如下。

首先，我使用Kafka對消息進行排隊。 接下來，我通過創建Storm拓撲來應用一些業務邏輯。最後，我將數據流推送到彈性搜索。

所有這些都捆綁到一個Maven項目中。在構建Maven項目之後，我必須手動將我的拓撲部署到Storm存儲庫。有沒有辦法讓這個過程自動化？這意味着，我可以創建/構建我的Maven項目嗎？只要它構建JAR，它就會將JAR和拓撲定義類的名稱一起上傳到Storm回購？

Answer 1

我不知道，您可以通過「上傳到風暴回購」的意思，不過，我想這exec-maven-plugin是你的朋友：http://www.mojohaus.org/exec-maven-plugin/

您可以在生成過程中觸發任意程序的執行。因此，你可以提供一個shell腳本來完成上傳，並在裝配完jar後調用它。