4
我一直想使用Apache Storm從Kafka流式傳輸。我更喜歡Python，所以我決定使用streamparse（https://github.com/Parsely/streamparse）。字數統計的例子就是介紹性的例子。我一直試圖讓它在我的本地機器上工作。我已經安裝了JDK，雷音和風暴以下版本：Streamparse wordcount示例
Leiningen 2.6.1 on Java 1.8.0_73 Java HotSpot(TM) 64-Bit Server VM
我運行以下streamparse後執行以下步驟：
sparse quick start wordcount cd wordcount sparse run
我收到以下錯誤：
Retrieving org/apache/storm/storm-core/0.10.1/storm-core-0.10.1.pom from central Retrieving org/apache/storm/storm/0.10.1/storm-0.10.1.pom from central Retrieving org/apache/storm/storm-core/0.10.1/storm-core-0.10.1.jar from central Could not transfer artifact com.parsely:streamparse:pom:0.0.4-SNAPSHOT from/to clojars (https://clojars.org/repo/): sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target Could not transfer artifact clojure-complete:clojure-complete:pom:0.2.4 from/to clojars (https://clojars.org/repo/): sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target This could be due to a typo in :dependencies or network issues. If you are behind a proxy, try setting the 'http_proxy' environment variable.
我project.clj文件如下所示：
(defproject wordcount "0.0.1-SNAPSHOT"
:source-paths ["topologies"]
: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" #"trident" #"META-INF" #"meta-inf" #"\.yaml"]
:uberjar-exclusions [#"log4j\.properties" #"backtype" #"trident" #"META-INF" #"meta-inf" #"\.yaml"]
)
因此，我的lein和風暴核心版本設置正確。我不知道我要去哪裏錯。有人能幫我嗎？
-Thanks