Wurden Kafka-Transaktionen verwendet (Exactly-Once-Semantik)?

Ja, Apache Kafka unterstützt Transaktionen, die die Semantik exactly-once beim Schreiben von Nachrichten gewährleisten. Dies wird durch einen transaktionalen Producer erreicht, der mehrere Schreibvorgänge in eine atomare Operation gruppiert. In Kotlin kann man die Kafka Producer API verwenden, um Transaktionen so zu konfigurieren, dass sichergestellt ist, dass Nachrichten entweder vollständig geschrieben werden oder gar nicht, um Duplikate bei Fehlern zu vermeiden.

Beispiel für die Initialisierung eines transaktionalen Producers 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 Operationen
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}