我一直想使用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路径构建失败:sun.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核心版本设置正确。我不确定我要去哪里错了。有人可以帮我吗?
-谢谢
缥缈止盈