Ich wollte Apache Storm verwenden, um von Kafka zu streamen. Ich fühle mich mit Python wohler und habe mich für streamparse entschieden https: //github.com/Parsely/streampars). Das Beispiel für die Wortanzahl ist das Einführungsbeispiel. Ich habe versucht, es auf meinem lokalen Computer zum Laufen zu bringen. Ich habe die folgende Version von JDK, Lein und Storm installiert:

Leiningen 2.6.1 on Java 1.8.0_73 Java HotSpot(TM) 64-Bit Server VM

Ich führe die folgenden Schritte aus, nachdem ich streamparse gefolgt habe:

sparse quick start wordcount
cd wordcount
sparse run

Ich erhalte den folgenden Fehler:

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.

ie Datei @My project.clj lautet wie folgt:

    (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"]
  )

Also, meine Lein- und Storm-Core-Versionen sind korrekt eingestellt. Ich bin mir nicht sicher, wo ich falsch liege. Könnte mir jemand helfen?

-Vielen Dan