apache-storm

0зной

2ответ

правильный способ создания проекта twitter heron с использованием intellij

Я пытаюсь запустить проект heron (или порт существующего проекта шторма) с использованием IntelliJ IDEA, но, к сожалению, я не могу заставить его работать. Я проверил все предложенные инструкции в Her

6зной

1ответ

Производитель Kafka не может обновить метаданные через некоторое время

У меня есть среда kafka, которая имеет 3 brokers и 1 zookeeper. Я нажал на> 20K сообщение в моей теме. Apache Storm вычисляет данные в теме, которая добавляется производителем. Через несколько часов п

8зной

1ответ

Apache Flink vs Twitter Heron?

Есть много вопросов, связанных с Flink vs Spark Streaming, Flink vs Storm и Storm vs Heron. Происхождение этого вопроса связано с тем, что как Apache Flink, так и Twitter Heron являются истинными стру

0зной

1ответ

java.lang.NoSuchMethodError: org.apache.storm.spout.MultiScheme.deserialize ([B) Ljava/lang/Iterable;

Я сейчас пытаюсь сделать тест на шторм 1.0.1. И я использовал топологию скомпилирована с бурой 0.9.5 и представить его в режиме обратной совместимости client.jartransformer.class: "org.apache.storm.ha

2зной

1ответ

Strom - Надежный Носик

Как установить Strom носик, как надежный Есть ли свойство установить надежен по умолчанию Как изменить Reliablity в kafkaSpout

0зной

1ответ

Невозможно получить сообщения в STORM NEW VERSION (1.0.1) из BEGINNING

Мы пытаемся получить сообщения в kafka с начала, используя STORM VERSION 0.9.3, и мы можем поместить его в HBASE TABLE. Для этого конфигурация которой мы использовали: kafkaConfig.forceFromStart = tru