Я пытаюсь написать приложение для приема пищи на GCP с использованием Apache Beam. Я должен написать его потоковым способом, чтобы читать данные из тем Kafka или pubsub, а затем загружать их в источник данных.
пока это кажется прямымжду, когда напишу его с использованием pubsub и apache beam, но мой вопрос: что произойдет, если мой прием не удастся или будет перезапущен, и если он снова считывает все данные из начала темы pubsub или как kafka, он может прочитать последние зафиксированные смещения в теме