apache-storm

0зной

1ответ

Можете ли вы добавить/удалить KafkaSpouts для топологии топологии Apache Динамически

У меня есть топология Apache Storm, которая принимает сообщения из нескольких тем Kafka. В настоящее время «множественный» означает «два». Как я в настоящее время только два KafkaSpouts, чтобы слушать

2зной

1ответ

Буря, если я установил количество исполнителей одного указанного болта на 1, то будет ли болт работать на одном фиксированном хосте все время?

Как и выше, я хочу, чтобы один болт работал только на одном хосте. Итак, если я установил номер исполнителя на 1, могу ли я достичь своей цели?

0зной

1ответ

Как определить задачи, выполняемые на узле в Apache Storm

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

0зной

1ответ

Apache Strom сбрасывает статистику после случайного периода времени

У меня есть топология с одним болтом и одним носиком. Он работает хорошо, но иногда вся статистика исчезает и начинает отсчитываться от нуля. Я не перезапускаю супервизоры, нимбы или что-то еще. Что м

1зной

2ответ

KafkaSpout (бездействует) генерирует огромный сетевой трафик

После разработки и выполнения моей топологии Storm (1.0.1) с помощью KafkaSpout и нескольких болтов я заметил огромный сетевой трафик, даже когда топология простаивает (на Kafka нет сообщений , обрабо

2зной

1ответ

Ошибка при попытке запустить STORM_TEST на потоковой скорости yahoo

Когда я пытаюсь протестировать STORM с использованием потокового теста yahoo, я получаю эти ошибки. Я попытался изменить порт на 2080 вместо стандартного порта 2181 в файле ZooKeeper zoo.cfg и kafka «

1зной

1ответ

storm-clojure.lang.Compiler $ CompilerException

Я столкнулся с этой проблемой в моей первой буре & примерах kafka. Похоже, что это из-за отсутствия clojure-1.4.0.jar. Но я добавил его к пути сборки проект. 9649 [main] ERROR org.apache.zookeeper.ser