Tag: streamparse

Streamparse wordcount示例

我一直想用阿帕奇风暴从卡夫卡stream。 我更喜欢Python，所以我决定使用streamparse（ https://github.com/Parsely/streamparse ）。 字数统计的例子就是介绍性的例子。 我一直在试图让它在我的本地机器上工作。 我已经安装了以下版本的JDK，lein和storm： Leiningen 2.6.1，Java 1.8.0_73 Java HotSpot（TM）64位服务器虚拟机 我遵循streamparse后运行以下步骤： 稀疏快速启动wordcount 裁谈会wordcount 稀疏运行 我得到以下错误： 从中央检索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 无法传输工件com.parsely：streamparse：pom：0.0.4-SNAPSHOT从/到clojars（https://clojars.org/repo/）：sun.security.validator.ValidatorException：PKIXpath构build失败：sun.security .provider.certpath.SunCertPathBuilderException：无法find有效的证书path到请求的目标 无法传输工件clojure-complete：clojure-complete：pom：0.2.4从/到clojars（https://clojars.org/repo/）：sun.security.validator.ValidatorException：PKIXpath构build失败：sun.security .provider.certpath.SunCertPathBuilderException：找不到要求的目标的有效证书path 这可能是由于：依存关系或networking问题。 […]