apache-storm

0зной

1ответ

Интеграция Kafka Storm с java. kafka.api.OffsetRequest.DefaultClientId() Ljava/языки/String; Ошибка

Я новичок в kafka и бурю. Я пытался реализовать Java-пример, который объединяет Кафку и шторм. Я нашел пример в Интернете. Я пытаюсь запустить java-программу в Eclipse IDE. Я не использую maven. У мен

2зной

1ответ

Разница между DSMS, Storm и Flink

DSMS соответствует системам управления потоками данных. Эти системы позволяют пользователям отправлять запросы, которые будут выполняться непрерывно, до момента их удаления пользователем. Могут ли сис

0зной

1ответ

Apache Storm: поддержка подстановочных знаков в слове Kafka

У нас есть топология с множеством задач кафки. Предполагается, что каждая задача носика должна читать подмножество сообщений из набора тем Kafka. Темы должны быть подписаны с использованием дикой карт

0зной

1ответ

Функция вызова шторма Apache из болта python

У меня есть простой штурмовой болт, которому нужно только вызвать функцию из другого модуля python. Все работает до тех пор, пока я не вызову метод, в котором есть функции печати внутри функции. Так м

4зной

1ответ

Недетерминированные функции в обработке потоков

Некоторые системы, такие как StreamScope, требуют детерминистических функций (а также порядка их обработки), это связано с тем, что каждое сообщение имеет свой порядковый номер, когда в потоке. В случ