我一直想使用Apache Storm從Kafka流式傳輸。我對Python較為滿意,因此我決定使用streamparse(https://github.com/Parsely/streamparse)。單詞計數示例是介紹性示例。我一直在嘗試使其在我的本地計算機上運行。我安裝了以下版本的JDK,lein和storm:Java 1.8.0_73 Java HotSpot(TM)64位服務器VM上的Leiningen 2.6.1我遵循streamparse之后運行以下步驟:稀疏快速啟動字數統計cd字數統計稀疏運行我收到以下錯誤:從中央檢索org / apache / storm / storm-core / 0.10.1 / storm-core-0.10.1.pom從中央檢索org / apache / storm / storm / 0.10.1 / storm-0.10.1.pom從中央檢索org / apache / storm / storm-core / 0.10.1 / storm-core-0.10.1.jar無法從/到Clojars(https://clojars.org/repo/)傳輸工件com.parsely:streamparse:pom:0.0.4-SNAPSHOT(https://clojars.org/repo/):sun.security.validator.ValidatorException:PKIX路徑構建失?。簊un.security .provider.certpath.SunCertPathBuilderException:無法找到到請求目標的有效證書路徑無法從/到Clojars(https://clojars.org/repo/)傳輸工件clojure-complete:clojure-complete:pom:0.2.4:sun.security.validator.ValidatorException:PKIX路徑構建失敗:sun.security .provider.certpath.SunCertPathBuilderException:無法找到到請求目標的有效證書路徑這可能是由于:dependencies或網絡問題引起的。如果您位于代理之后,請嘗試設置“ http_proxy”環境變量。我的project.clj文件如下所示: (解項目字數“ 0.0.1-SNAPSHOT” :source-paths [“拓撲”] :resource-paths [“ _resources”] :target-path“ _build” :min-lein-version“ 2.6.1” :jvm-opts [“ -client”] :dependencies [[org.apache.storm / storm-core“ 0.10.1”] [com.parsely / streamparse“ 0.0.4-SNAPSHOT”] ] :jar-exclusions [?!?log4j \ .properties”?!?backtype”?!叭骊保!?META-INF”#“ meta-inf”?!?\。yaml”] :uberjar-exclusions [#“ log4j \ .properties”?!?backtype”?!?trident”#“ META-INF”?!?meta-inf”?!?\。yaml”] )因此,我的lein和Storm核心版本設置正確。我不確定我要去哪里錯了。有人可以幫我嗎?-謝謝
Streamparse單詞計數示例
慕運維8079593
2019-11-20 10:07:01