apache-storm

0熱度

2回答

我的公司有一個B2C網站，每天爲數千個網頁用戶提供服務。它使用PHP，angular.js和MySQL。我們喜歡加入新的技術領域，我們看到一些熱門趨勢是卡夫卡/火花/風暴。我們如何在架構中使用這些技術，以及如何從中受益？感謝

0熱度

2回答

錯誤：發生了JNI錯誤，請檢查您的安裝並重試.NoClassDefFound錯誤：DRPCExecutionException

當我嘗試連接到DRPC客戶端請求的storm-topology（v1.0.2）時，出現以下錯誤： ERROR: A JNI error has occurred, please check your installation and try again. exception in thread "main" java.lang.NoClassDefFoundError:org/apache/sto

2熱度

1回答

如何爲每個使用Apache Storm的用戶創建Drools規則文件？

我們正在製作Storm應用程序，那裏我們需要爲每個用戶創建規則文件。有沒有可能？

1熱度

2回答

kryo序列化風暴

我需要通過apache風暴（部署在遠程集羣中）序列化複雜對象（opencv：Mat）。任何人都可以建議我一個很好的教程自定義kryo序列化或提出解決方案如何做到這一點？在此先感謝！

1熱度

1回答

集羣中的拓撲可以寫入本地文件系統的txt文件嗎？（運行在同一個系統上的集羣）

當前正在開發一個項目，爲了從TI-SensorTag CC2650獲取傳感器值，通過HTTP（通過Apache-TomCat-Servlet）將該值通過python腳本發送到Apache- Kafka並將Kafka與Apache-Storm連接起來處理數據。此數據將通過拓撲中的螺栓被寫入本地系統上的.txt文件（Apache-Storm-Cluster-Folder的目錄）。我剛開始與風暴和卡

0熱度

1回答

netbeans - 如何在Netbeans中關閉Apache Storm的拓撲結構？

我的項目使用Maven。要執行拓撲，我只需在Netbeans中運行拓撲文件。問題是我不知道如何關閉它。我不想停止執行程序（停止按鈕）。我想告訴拓撲它需要關閉。我該怎麼做？

0熱度

1回答

Storm拓撲未開始處理

我正在啓動一個Storm v1.0.1集羣，其中包含1個nimbus和4個supervisor節點。我有2個zookeeper節點。當我嘗試發佈應該從Kafka消費的示例拓撲時。然而，在topolgy提交後，在檢查靈氣和主管日誌後，我發現工作人員沒有啓動。 storm.yaml storm.zookeeper.servers: - "storage14" - "storage1

0熱度

1回答

使用Storm Crawler進行爬網

我們正試圖實施Storm Crawler來抓取數據。我們已經能夠從網址中找到子鏈接，但我們希望從這些子鏈接中獲取內容。我一直沒有找到能夠指導我如何得到它的很多資源？任何有用的鏈接/網站在這方面將是有益的。謝謝。

1熱度

1回答

FieldGrouping ID在Storm中意味着什麼？

這是配置： TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("1", new Produce(), 1); builder.setBolt("2", new Output(), 4).shuffleGrouping("1"); builder.setBolt("3", new Writer(), 8).fie

1熱度

2回答

Storm-Kafka：java.lang.NoClassDefFoundError：com/google/common/base/Strings

我想使用storm-core 1.0.2和kafka-spout 1.0.2來運行風暴LocalCluster。我的POM文件看起來像下面 <dependencies>  <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm