apache-storm

0зной

1ответ

Как получить предыдущее состояние перед обновлением счетчика

У меня есть, например, эти партии кортежей с размером партии 5 с впечатлениями от пользователей: Batch 1: [UUID1, clientId1] [UUID2, clientId1] [UUID2, clientId1] [UUID2, clientId1] [UUID3, clien

3зной

1ответ

Cassandra Storm Integration

Я смотрел на Storm-Cassandra Пример построения решения для моего приложения. Из примеров в https://github.com/hmsonline/storm-cassandra Я считаю, что кортежи и разыгрывающий болт, который излучает к б

0зной

1ответ

Получение сообщений от kafka с помощью шторма

Как получить последнее время смещения от zookeeper? при чтении сообщений от кафки с использованием штормового желоба. Контекст: Кафка получает сообщения непрерывно, потребитель читает на некоторое вре

4зной

2ответ

Не удалось выполнить цель org.codehaus.mojo: exec-maven-plugin: 1.2.1 - интеграция kafka storm

Я работаю над интеграцией kafka strom. Я застрял с ошибкой. Сложение Сбой при попытке запустить его с помощью mvn -e -f m2-pom.xml compile exec:java -Dexec.classpathScope=compile -Dexec.mainClass=stor

1зной

1ответ

Strom API в Windows

Can Storm API будет установлен в операционной системе Windows? Я разместил Storm-0.8.1 в «Мои документы» и обновил переменную PATH, но система не распознает команду storm.I думаю, что я загрузил верси