Итак, я использую storm-kafka-client, чтобы подписать мою топологию на тему Kafka.Так как мне нужна...

В моей топологии учета времени в окне процесса скорость ввода составляет 2000 туплей / с.Размер...

Когда я проверяю источник StormCrawler, есть много полезных журналов отладки.Но если поместить...

builder.setSpout("spout", new TweetSpout()); builder.setBolt("bolt", new...

Version Info: "org.apache.storm" % "storm-core" % "1.2.1" "org

Я реализовал топологию цапли, которая читает сообщения из очереди Кафки. Следовательно, моя...

У меня возник вопрос по поводу использования кардиостимулятора. В настоящее время у нас работает...

Когда я запускаю топологию Storm с KafkaSpout в Heron, происходит следующее exception: [2018-11-01...

Я хочу точно знать пропускную способность в Apache Storm. Количество обработанных кортежей / Общее...

Version Info: "org.apache.storm" % "storm-core" % "1.2.1" "org

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

Следуя инструкции «Интеграция Kafka и Storm: примеры кода и состояние игры» - http://www.michael...

Я использую шторм V1.2.1.После настройки в соответствии с официальной документацией я хочу получить...

Кто-нибудь настраивал Storm Nimbus, Supervisors и UI-контейнеры в Kubernetes?Если да, то какую...

Мне нужно передать лямбда-функцию в качестве параметра конструктору или методу в файле конфигурации...

Во время инициализации Apache's Storm JdbcInsertBolt я получаю ошибку java.lang.ClassCastException:...

Я создаю Spring-приложение в Java 9 с Apache Storm 1.1.2 и Kafka 0.11 Я заметил, что при высокой...

Я пытаюсь интегрировать Кафку с топологией Герона.Однако я не могу найти никаких примеров с...

У меня есть штормовой болт, который отвечает за извлечение содержимого электронного письма.Я хотел...

Я использую топологию шторма в локальном режиме. Во время запуска шторма zookeeper и nimbus...

пытаюсь использовать шторм HDFS spout, у меня Apache Nifi перемещает файлы в каталог HDFS, где...

Я вижу, что SLF4J используется для регистрации записей во время выполнения компонентов stormcrawler

У меня есть топология Apache Storm (v1.2.1), которая использует ShellBolt для выполнения сценария...

У меня есть топология Storm, где я должен отправлять вывод в kafka, а также обновлять значение в...

У меня есть настройка топологии шторма (1 рабочий), в которой spout (в java) удаляет (используя...