Χρησιμοποιήθηκαν συναλλαγές Kafka (ακριβώς μια φορά σημασιολογία);

Ναι, το Apache Kafka υποστηρίζει συναλλαγές που διασφαλίζουν την ακριβή-once σημασιολογία κατά την εγγραφή μηνυμάτων. Αυτό επιτυγχάνεται με έναν συναλλαγικό παραγωγό που ομαδοποιεί πολλαπλές εγγραφές σε μια ατομική λειτουργία. Στην Kotlin, χρησιμοποιώντας το API του Kafka Producer, μπορείτε να διαμορφώσετε συναλλαγές ώστε να διασφαλίσετε ότι τα μηνύματα είτε εγγράφονται πλήρως είτε καθόλου, αποφεύγοντας διπλοεγγραφές σε περίπτωση σφαλμάτων.

Παράδειγμα αρχικοποίησης ενός συναλλαγικού παραγωγού στην 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"))
    // άλλες λειτουργίες
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}