apache-storm

1зной

1ответ

Как обрабатывать ACKing в шторме с несколькими болтами чтения из того же носика

Моя топологии выглядит следующим образом: Data_Enrichment_Persistence_Topology Поэтому в основном проблема, которую я пытаюсь решить здесь является то, что каждый раз, когда какой-либо вопрос приходит

0зной

1ответ

Storm Topology/KafkaSpout не работает кортежи тихо и медленно замедляется

Я использую топологию Storm (со Storm 0.10.0) с KafkaSpout по умолчанию, чтобы получать данные JSON, поступающие из темы Kafka и обрабатывая ее. Иногда топология достигает 500 тыс. Сообщений в секунду

0зной

1ответ

Скрыть значение конфигурации для шторма UI

Штормовой интерфейс отображает все значения конфигурации, включая ключ шифрования blowfish. Есть ли способ скрыть часть значения конфигурации от публики?

0зной

1ответ

Многополосная функция Storm

Я новичок в Storm. Недавно я пытаюсь использовать многоязычные функции Storm. Однако у меня есть очень наивные путаницы. Я думал, что взаимодействие MultiLang Шторма должен прийти с storm.py, storm.js

0зной

1ответ

Уточнение скорости вывода носика в шквал апача

Как ограничить перенос кортежа в секунду без использования команды «Сон» в шторме апачей? например, я не хочу использовать этот код. Спасибо puplic Void Next Tuple(){ utils.sleep(time); }

0зной

1ответ

Как включить ведение журнала GC для процессов Apache Storm, предотвращая перезапись файла журнала и ограничение использования дискового пространства

Мы недавно решили включить GC-протоколирование для нескольких процессов Apache Storm: Nimbus, UI, DRPC-сервер, супервизор и logviewer. (Штормовые работники покрываются другим вопросом: How to enable G

1зной

2ответ

Storm UI throwing «Смещение задержки для kafka не поддерживается для более старых версий. Обновите версию kafka до последней версии».

Я обновил кластер hdp до 2,5 и обновил топологические зависимости штормового ядра до 1.0.1 и штормового кафки до 1.0.1. После развертывания новой топологии с новыми зависимостями 1.0.1 все работает та

0зной

1ответ

storm-starter отсутствует класс org.apache.storm.localcluster

Я хочу использовать шторм как решение для обработки событий. Я хочу переслать события из ELK, чтобы штурмовать и добавить код в шторм. Я пытался запустить код ливневых стартера: https://github.com/apa

0зной

1ответ

Как настроить storm.yaml, когда кластер zookeeper использует другой порт?

Я настроил кластер zookeeper с 3 серверами, и он работает хорошо. Однако на 3 серверах используется другой порт. Например, «zk0» использует порт 2181, «zk1» использует порт 2182, а «zk2» использует по