У меня есть ситуация, когда я собирал данные из кинесиса AWS для запуска Apache по потоковой передаче.После того, как я получаю данные за период, я обрабатываю эти данные и обновляю их в cassandra.Здесь обработка должна выполняться таким образом, чтобы до тех пор, пока результат не будет обновлен в Кассандре, спарк не должен получать следующую партию записей.Итак, как остановить потоковую передачу следующего пакета записи, пока текущий пакет не будет обработан?