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

Мы наблюдаем некоторые проблемы с производительностью с Kafka + Storm + Trident + OpaqueTridentKafkaSpout Ниже указаны детали нашей установки: Топология шторма: Broker broker = Broker.fromString("localhost:9092")...

Я новичок в Trident. Я пишу топологию трезубца, которая считывает данные из кафки. Название темы - «тест». У меня локальная настройка кафки. Я запустил zookeeper, кафку на местном уровне. И создал тему «тест» в кафке, открыл продюсер и набрал...

Я хочу использовать в проекте Apache Storm TridentTopology. Мне трудно понять функцию .each() из класса storm.trident.Stream. Ниже приведен пример кода, приведенный в их учебнике для справки: TridentTopology topology = new TridentTopology();...

Есть ли способ динамически создавать топологии в Trident? Может ли кто-нибудь привести примеры?

Я только что реализовал функцию Trident DRPC для обработки входящих сообщений, и я пытаюсь сохранить количество обработанных кортежей на заключительном этапе топологии как состояние Trident. Вот моя топология: topology.newDRPCStream("portfolio")...