Я использую шторм 1.0.x, но когда я пытаюсь использовать ниже // Instantiate spout to read text...

Мы обрабатывали данные в реальном времени, периодически данные помещались в эластичный поиск. Мне...

Я пытаюсь развернуть простую топологию в Streamline. Получение простой структурированной информации...

Я разработал проект, который читает сообщения от Кафки и обрабатывает их в Storm. Тем не менее, я...

Я пытаюсь запустить топологию с Windowed Bolt, но получаю следующее исключение: Exception in thread...

В чем разница между объектами KafkaSpout и KafkaBolt? Обычно KafkaSpout используется для чтения...

Есть ли какая-то конкретная разница между Отправителем и Кластером? Когда я использовал...

Что такое зависимость Maven для импорта org.apache.storm.kafka.bolt.KafkaProducerTopology Я...

Я читаю текстовые данные из файла и обрабатываю их для получения результатов с помощью Apache Storm

Я хочу изменить каталог файлов журнала для шторма и мои собственные журналы Я работаю над локальным...

Как отправить запись Consumer в объект Storm Spout в одной строке кода? У меня есть два экземпляра,...

у нас запущена топология шторма на Java. Есть болт, который использует скрипты Python. Для этого мы...

Я новичок в python и использую шторм (1.0.1) на hdinsight. Когда я искал, все, что я могу видеть,...

Я запускаю штормовую банку в кластере, где я настроил hadoop, kafka, штормовую группу когда я...

Я использую Apache Storm с Nimbus, настроенным на одном узле, и двумя супервизорами, настроенными...

Я настроил кластер Kafka, кластер Storm и кластер Hadoop. все работает нормально, когда у них нет...

У меня есть топология Apache Storm и я хотел бы время от времени выполнять определенные действия. Я...

Версии: "org.apache.storm" % "storm-kafka-client" % "1.2.1" "org

Как создать Tumbling Window в Storm с обоими пороговыми значениями. Например, если я установил...

В проекте, над которым я работаю, я должен повторно использовать проект, использующий шторм 0.9.7....

Я пытался интегрировать болт, созданный в python, в топологию, построенную с использованием...

Я настроил развертывание штормового венчика и другое развертывание штормового супервизора (и...

Я пытался интегрировать простой болт Python в уже настроенную топологию шторма, созданную с...

Я работаю над переносом моего старого инструмента индексирования в solr (версия 7).Но я не совсем...

Наша топология использует KafkaSpout для извлечения сообщений из тем Кафки.У нас есть ~ 150 тем с ~...