У меня есть приложение, в котором я создал экземпляр Jet и задание конвейера для агрегирования результатов потоковых данных.Я запускаю несколько экземпляров такого приложения.Проблема, с которой я сталкиваюсь, состоит в том, что, поскольку есть 2 установки, она выполняет 2 конвейерных задания, и, следовательно, результат вычисляется дважды и неверно, но выясняет, что оба экземпляра Jet являются частью одного кластера.
Разве реактивный конвейер не проверяет работу конвейера и, если он совпадает, просто считает его одним, как поток Кафки, делает это с его топологией?