ретрая упавшего таска (вроде 3 раза в дефолте) , новый таск читает диапазон оффсетов в виде отрезка[start_first_try, end_end_first_try] или [Lastoffset_from_checkpoint, +inf]?
мне кажется, вы не сможете вообще какие-то гарантии об этом найти. я бы не парился и делал бы дедуп батчами уже в клике или что там, если на заливке невозможно обеспечить недорогой upsert
Обсуждают сегодня