Kafka ტრანზაქციები გამოიყენეს (ზუსტად ერთხელ სემანტიკა)?

დიახ, Apache Kafka-ს აქვს მხარდაჭერა ტრანზაქციებისთვის, რომლებიც უზრუნველყოფენ ზუსტად ერთხელ (exactly-once) სემანტიკას შეტყობინებების ჩაწერის დროს. ეს მიღწეულია ტრანზაქციული პროდიუსერის საშუალებით, რომელიც ჯგუფავს რამდენიმე ჩანაწერს ერთ ატომურ ოპერაციაში. Kotlin-ში, Kafka Producer API-ს გამოყენებით, შეგიძლიათ კონფიგურაცია ტრანზაქციებისთვის, რათა გარანტირებული იყოს, რომ შეტყობინებები ან სრულად იწერება, ან საერთოდ არა, თავიდან აიცილოთ დუბლიკაცია სარღვევების დროს.

ტრანზაქციული პროდიუსერის ინიციალიზაციის მაგალითი 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()
}