apache-storm

3зной

3ответ

Ошибка связывания диспетчера бури, загружающая банку с nimbus

Я настраиваю кластер кластера с несколькими узлами. Таким образом, у меня есть 3 узла zookeeper, 1 nimbus, 2 супервизора и 1 штормовой клиентский узел. Поэтому, когда я смотрю на свои настройки с помо

-1зной

2ответ

Storm - KeeperException

Я запускаю кластер штормов. У меня есть nimbus, zookeeper, Kafka server и супервизор в одном узле, и другой супервизор в отдельном узле. Когда я развертываю топологию, имеющую простой первый кафка в п

1зной

2ответ

Каким образом можно передавать XML-файлы (размером 500-600 КБ) в виде сообщений Kafka?

Я хочу прочитать потоковые XML-файлы и проанализировать их в Apache Storm. Я использую Kafka как систему MQ для очереди XML-файлов размером ~ 500 КБ. Я хочу передать весь файл в виде сообщения в Kafka

0зной

1ответ

Обработка потока данных UDP с MapReduce

У меня проблема с обработкой потока UDP в реальном времени с системой уменьшения карты. На самом деле я делаю университетский проект, и я хочу использовать mapreduce для обработки этих данных. Поток U

2зной

2ответ

nextTuple() называется бесконечным временем с использованием BaseRichSpout on Storm

Я реализовал простую топологию Storm с одним носиком и болтом, работающим в локальном режиме кластера. по какой-либо причине nextTuple() носика называется более одного раза. Любая идея, почему? код: н