我一直想使用Apache Storm從Kafka流式傳輸。我對Python較為滿意,因此我決定使用streamparse(https://github.com/Parsely/streamparse)。單詞計數(shù)示例是介紹性示例。我一直在嘗試使其在我的本地計算機上運行。我安裝了以下版本的JDK,lein和storm:Java 1.8.0_73 Java HotSpot(TM)64位服務(wù)器VM上的Leiningen 2.6.1我遵循streamparse之后運行以下步驟:稀疏快速啟動字數(shù)統(tǒng)計cd字數(shù)統(tǒng)計稀疏運行我收到以下錯誤:從中央檢索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路徑構(gòu)建失?。簊un.security .provider.certpath.SunCertPathBuilderException:無法找到到請求目標(biāo)的有效證書路徑無法從/到Clojars(https://clojars.org/repo/)傳輸工件clojure-complete:clojure-complete:pom:0.2.4:sun.security.validator.ValidatorException:PKIX路徑構(gòu)建失敗:sun.security .provider.certpath.SunCertPathBuilderException:無法找到到請求目標(biāo)的有效證書路徑這可能是由于:dependencies或網(wǎng)絡(luò)問題引起的。如果您位于代理之后,請嘗試設(shè)置“ http_proxy”環(huán)境變量。我的project.clj文件如下所示: (解項目字數(shù)“ 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核心版本設(shè)置正確。我不確定我要去哪里錯了。有人可以幫我嗎?-謝謝
Streamparse單詞計數(shù)示例
慕運維8079593
2019-11-20 10:07:01