Kafka Connect без магии: как переносить данные и не писать еще один сервис

А как Kafka Connect ведет себя при повторной обработке данных после сбоя? Насколько реально получить дубли при падении worker’а между записью сообщения в Kafka и сохранением source offset, и как обычно решают эту проблему на практике?