apache-kafka apache-storm streamparse

apache kafka - Streamparse ejemplo de recuento de palabras



apache-kafka apache-storm (2)

Esto se debe a que Java no reconoce el certificado SSL de la autoridad de certificación raíz (CA) de https://clojars.org/repo .

La solución es agregar ese certificado al archivo jace cacerts para que sea aceptado permanentemente.

Paso 1: Obtenga el certificado raíz de https://clojars.org

  1. Abra https://clojars.org en un navegador Chrome.
  2. localice el símbolo de bloqueo justo al lado de su barra de direcciones y haga clic en él.
  3. ver detalles
  4. Haga clic en la parte superior de la mayoría de los certificados en la jerarquía y confirme que se sigue con la frase Root CA.
  5. arrastre y suelte la imagen que vio en el escritorio del certificado escrito.

¡Eso es! tienes tu certificado de root!

Paso 2: Obtenga ese certificado agregado al archivo java cacerts.

  1. use keytool.exe dentro de su carpeta jre bin.
  2. active el siguiente comando para colocar su certificado dentro del archivo cacerts

keytool –import –noprompt –trustcacerts –alias ALIASNAME -file /PATH/TO/YOUR/DESKTOP/CertificateName.cer -keystore / PATH / TO / YOUR / JDK / jre / lib / security / cacerts -storepass changeit

¡Eso es! Tienes tu problema resuelto.

TENGA EN CUENTA

  1. Confirme que el jre que le está dando este error PKIX (JRE utilizado por KAFKA) es donde está ejecutando el PASO 2. Si intentara con otro problema jre sería como es.

  2. Use solo un jre que esté dentro de JDK, ya que disminuye la posibilidad de tener problemas.

He estado queriendo usar Apache Storm para transmitir desde Kafka. Me siento más cómodo con Python, así que decidí usar streamparse ( https://github.com/Parsely/streamparse ). El ejemplo de conteo de palabras es el ejemplo introductorio. He estado tratando de que funcione en mi máquina local. Tengo instalada la siguiente versión de JDK, lein y storm:

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

Ejecuto los siguientes pasos después de seguir streamparse:

sparse quick start wordcount cd wordcount sparse run

Obtuve el siguiente 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.

Mi archivo project.clj dice así:

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

Entonces, mis versiones lein y storm core están configuradas correctamente. No estoy seguro de dónde me estoy equivocando. ¿Alguien podría ayudarme?

-Gracias

Si está utilizando Debian o Ubuntu, puede ejecutar:

$ sudo update-ca-certificates -f