У меня есть три топологии, слушающие одну и ту же тему Кафки и записывающие данные в разные таблицы...

Я потерял свой кластер kubernetes и перестраиваюсь. Я хотел бы восстановить тома, которые были...

Мне нужна свежая и надежная статистика о движках рендеринга в качестве источника для моей...

Как и в случае с prometheus storage.md, рекомендуется не использовать хранилище NFS в качестве...

Apache Storm и Samza гарантируют как минимум однократную доставку.Это означает, что в процессе...

Я хочу реализовать простой конвейер, который бы считал слова за 5 секунд фиксированного окна:...

Я только что реализовал функцию DRPC трезубца для обработки входящих сообщений, и я пытаюсь...

Я пытаюсь обновить документы в Elasticsearch, используя сообщения Kafka (как StreamSource). Запись...

Здесь Документация шторма гласит: CombinerAggregator возвращает один кортеж с одним полем в...

Версия Storm : 1.0.3 Я регистрирую пользовательскую метрику в makeState реализации StateFactory....

Как найти слово с максимальным количеством в топологии подсчета слов, используя топологию Trident

Я использую storm + kafka + protobuf для создания своей системы потоковых процессов. Проблема в том...

Пример подсчета слов использует LONG в качестве счетчика для завершения штормового состояния /...

У меня много целевых чисел для суммирования для одного и того же условия фильтрации. Используйте...

Я использую штормовый трезубец, встроенный в Min с hbase state / mapper в разработке. До разработки...

Я читаю данные из 2 тем кафки.Который может быть описан как: Topic1 data content:...

Я использую OpaqueTridentKafkaSpout для приема сообщений от Kafka.Ниже приведен код.Я...

Где хранятся разделы Kafka и соответствующие смещения при использовании сообщений от Kafka с...

Я использую storm-kafka-client 1.2.1 и создаю конфигурацию spout для KafkaTridentSpoutOpaque, как...