Если по какой-то причине нам необходимо отключить кластер kafka и с помощью искровой потоковой передачи мы продолжаем получать потоковые данные, как мы планируем отключение для кластера kafka.Здесь, если кластер kafka не работает, мы все равно получим данные из потоковой передачи искры, а если не обработать должным образом, мы потеряем некоторые данные.
Посоветуйте, пожалуйста, как мы можем справиться с этим сценарием?
Я попытался выполнить поиск, но не смог получить ответ на этот вопрос.