Des transactions Kafka ont-elles été utilisées (sémantique exactement une fois) ?

Oui, Apache Kafka prend en charge les transactions qui garantissent la sémantique exactly-once lors de l'écriture de messages. Cela est réalisé à l'aide d'un producteur transactionnel qui regroupe plusieurs écritures en une opération atomique. En Kotlin, en utilisant l'API du producteur Kafka, vous pouvez configurer des transactions pour garantir que les messages sont entièrement écrits ou pas du tout, évitant ainsi les doublons en cas de panne.

Exemple d'initialisation d'un producteur transactionnel 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"))
    // autres opérations
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}