¿Se utilizaron transacciones Kafka (semántica exactamente una vez)?

Sí, Apache Kafka admite transacciones que garantizan la semántica exactly-once al escribir mensajes. Esto se logra mediante un productor transaccional que agrupa varias escrituras en una operación atómica. En Kotlin, usando la API del productor de Kafka, se pueden configurar transacciones para garantizar que los mensajes se escriban completamente o no se escriban en absoluto, evitando duplicados en caso de fallos.

Ejemplo de inicialización de un productor transaccional en 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"))
    // otras operaciones
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}