У меня та же ситуация, что описана в Структурированная пересылка Spark из kafka - последнее сообщение обрабатывается снова после возобновления с контрольной точки . Когда я перезапускаю свое задание искры после сбоя, последнее сообщение снова...