apache-storm

0зной

1ответ

Как разрешить шторм кафка носик только потребителя половину данных от кафки?

<dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-core</artifactId> <version>1.0.2</version> <scope>provided</scope> </dependency> <dependency> <groupI

0зной

1ответ

Inject внешние свойства для Apache Storm Flux

Я использую Flux 1.0.0, и я переписал свою топологию в файл YAML. Но у меня есть некоторые свойства, которые раньше были частью конфигурации, с которой я использовал драйвер Storm. storm.Driver --conf

1зной

1ответ

Как определить, когда увеличить параллелизм одного работника или увеличить рабочих в шторме?

В веб-сайте штормовой (storm) wrirtes: «Способности» метрика является очень полезным и говорит вам, что% времени в течение последних 10 минут болт, потраченное на выполнение кортежи. Если это значение

0зной

1ответ

Как написать пробный носик kafka с помощью нового API-интерфейса Kafka?

Нравится шторм-кафка-клиент, меня использовал штормовой кафка-клиент, но он не может хорошо работать, а новый носик тоже не работает. Кто может помочь мне написать пробный кафка.

1зной

1ответ

NoClassDefFoundError StanfordCoreNLP

У меня есть эта проблема, когда я устал подавать топологию в local mode! ERROR backtype.storm.util - Async loop died! java.lang.NoClassDefFoundError: edu/stanford/nlp/pipeline/StanfordCoreNLP at edu

0зной

1ответ

Storm DRPC Клиенты

Я работаю над Storm, создавая топологию с потоком DRPC. Я создал топологию, развернул ее, и у меня есть Java DRPCClient. Все это прекрасно работает как на местном, так и на удаленном. Однако меня инте

3зной

1ответ

путь Класс содержит несколько привязок SLF4J

я пытался отладить мой проект, но получил это SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/usr/local/storm/lib/logback-classic-1.0.13.jar!/org/slf4j/impl/Sta