Zijn Kafka-transacties gebruikt (exact één keer semantiek)?

Ja, Apache Kafka ondersteunt transacties die de exactly-once semantiek garanderen bij het schrijven van berichten. Dit wordt bereikt met behulp van een transactionele producer die meerdere schrijfbewerkingen in één atomair proces groepeert. In Kotlin, met behulp van de Kafka Producer API, kunnen transacties worden geconfigureerd om te garanderen dat berichten volledig worden geschreven of helemaal niet, waardoor duplicatie bij storingen wordt voorkomen.

Voorbeeld van het initialiseren van een transactionele producer in 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"))
    // andere operaties
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}