Kafka - как реализовать дедубликацию при падении приложения?

Есть приложение, читает файл построчно и передаёт в Kafka. При падении приложения и затем восстановлении, необходимо продолжить или заново начать отправку в Kafka, но чтобы не дублировать ранее отправленные строки. Kafka даёт какие либо инструменты для решения этой проблемы? идемпотентность и exactly one это то, что мне нужно?