Пример примера streamparse wordcount

Я хотел использовать Apache Storm для streamовой передачи из Kafka. Мне больше нравится Python, поэтому я решил использовать streamparse ( https://github.com/Parsely/streamparse ). Пример подсчета слов – вводный пример. Я пытался заставить его работать на моей локальной машине. У меня установлена ​​следующая версия JDK, лейн и шторм:

 Leiningen 2.6.1 на Java 1.8.0_73 Java HotSpot (TM) 64-разрядная серверная VM

После выполнения команды streamparse выполните следующие шаги:

 редкий быстрый старт wordcount
 cd 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 из / в клоары (https://clojars.org/repo/): sun.security.validator.ValidatorException: не удалось создать путь к PKIX: sun.security .provider.certpath.SunCertPathBuilderException: не удается найти допустимый путь сертификации для запрошенной цели
 Не удалось передать артефакт clojure-complete: clojure-complete: pom: 0.2.4 from / to clojars (https://clojars.org/repo/): sun.security.validator.ValidatorException: не удалось создать путь PKIX: sun.security .provider.certpath.SunCertPathBuilderException: не удается найти допустимый путь сертификации для запрошенной цели
 Это может быть связано с оговоркой в ​​отношении: зависимостей или сетевых проблем.
 Если вы находитесь за прокси-сервером, попробуйте установить переменную среды «http_proxy».

Файл project.clj читается следующим образом:

     (defproject wordcount "0.0.1-SNAPSHOT"
       : исходные пути ["топологии"]
       : ресурсы-пути ["_resources"]
       : target-path "_build"
       : мин-лейн-версия "2.6.1"
       : jvm-opts ["-client"]
       : зависимости [[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"]
   )

Итак, мои базовые версии лейн и шторма установлены правильно. Я не знаю, где я ошибаюсь. Может ли кто-нибудь помочь мне?

-Благодаря

Это связано с тем, что java не признает сертификат SSL-сертификата корневого центра сертификации (CA) https://clojars.org/repo .

Решение заключается в том, чтобы добавить этот сертификат в файл java cacerts, чтобы он был принят навсегда.

Шаг 1. Получите корневой сертификат https://clojars.org.

  1. Откройте https://clojars.org в браузере Chrome.
  2. найдите значок блокировки, помимо вашей адресной строки, и нажмите на нее.
  3. посмотреть детали
  4. Нажмите на самый верхний сертификат по иерархии и подтвердите, что он связан с фразой Root CA.
  5. перетащите изображение, которое вы видели на рабочем столе.

Это оно! вы получили свой корневой сертификат!

Шаг 2. Получите этот сертификат, добавленный в файл java cacerts.

  1. используйте keytool.exe внутри папки jre bin.
  2. пожарная команда, чтобы поместить ваш сертификат в файл cacerts

keytool -import -noprompt -trustcacerts -alias ALIASNAME -файл /PATH/TO/YOUR/DESKTOP/CertificateName.cer -keystore / PATH / TO / YOUR / JDK / jre / lib / security / cacerts -storepass changeit

Вот и все! вы решили проблему.

ПОЖАЛУЙСТА, ОБРАТИТЕ ВНИМАНИЕ

  1. Подтвердите, что jre, который дает вам эту ошибку PKIX (JRE, используемую KAFKA), где вы выполняете STEP 2. Если вы попытаетесь с другой проблемой, проблема будет такой, какая есть.

  2. Используйте только один jre, который находится внутри JDK, он уменьшает вероятность возникновения проблем.

Если вы используете debian или ubuntu, вы можете выполнить:

$ sudo update-ca-certificates -f 
Interesting Posts

Как настроить IP-адрес окон 7 и windows xp через беспроводной маршрутизатор для создания сетей?

Повторный ввод серийного номера в Windows 7

Как изменить выбранное значение выпадающего списка select2 с помощью JqGrid?

setOpaque (истина / ложь); Ява

Присвоить строку, содержащую нулевой символ (\ 0), переменной в Bash

Округление странности – что особенного в «100»?

Компиляция classа Java в памяти с помощью аннотаций `lombok` и Java JDK 8

Как изменить имя приложения Ruby on Rails?

Функция «отменить отправку» Thunderbird (как в Gmail)?

Как получить все сообщения, расширенные в режиме разговора в Outlook 2013?

Каков правильный способ использования printf для печати clock_t?

Условно скрыть CommandField или ButtonField в Gridview

Как настроить вторую сетевую карту для использования на рабочей станции VMWare?

Как отобразить диалоговое окно только при успешном заполнении формы

java.lang.NoClassDefFoundError: javax / servlet / jsp / jstl / core / Config

Давайте будем гением компьютера.