Foram utilizadas transações Kafka (semântica exatamente uma vez)?

Sim, o Apache Kafka suporta transações que garantem a semântica exactly-once ao gravar mensagens. Isso é alcançado usando um produtor transacional que agrupa várias gravações em uma operação atômica. Em Kotlin, usando a API do produtor Kafka, é possível configurar transações para garantir que as mensagens sejam totalmente gravadas ou não gravadas de forma alguma, evitando duplicações em caso de falhas.

Exemplo de inicialização de um produtor transacional em Kotlin:

val props = Properties().apply {
    put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092")
    put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer::class.java.name)
    put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer::class.java.name)
    put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, "true")
    put(ProducerConfig.TRANSACTIONAL_ID_CONFIG, "my-transactional-id")
}

val producer = KafkaProducer<String, String>(props)
producer.initTransactions()

try {
    producer.beginTransaction()
    producer.send(ProducerRecord("topic", "key", "value"))
    // outras operações
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}