I wanted to use Apache Storm to stream from Kafka. I like Python more, so I decided to use streamparse ( https://github.com/Parsely/streamparse ). An example of word counting is an introductory example. I tried to make it work on my local machine. I have the following version of JDK, lane and storm installed:
Leiningen 2.6.1 on Java 1.8.0_73 Java HotSpot (TM) 64-Bit Server VM
I followed these steps after the following thread:
sparse quick start wordcount
cd wordcount
sparse run
I get the following error:
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 storm . , . - ?
-