Как использовать потоковую обработку spark strcutured для пакетных запросов, как мне прочитать определенный пакет, обработать его и сохранить смещения, чтобы последующий запуск задания начинал расходоваться с того места, где оно было остановлено в первый раз?