Kafka əməliyyatları istifadə olundu mu (dəqiq bir dəfə semantika)?

Bəli, Apache Kafka mesajların yazılmasında tam dəqiqliklə işləmə semantikası təmin edən tranzaksiyaları dəstəkləyir. Bu, bir neçə yazmanı atomik əməliyyatda qruplaşdıran tranzaksiya istehsalçı vasitəsilə həyata keçirilir. Kotlin-də Kafka Producer API-dən istifadə edərək, tranzaksiyaları konfiqurasiya etmək və mesajların tam və ya heç yazılmamasını təmin etmək mümkündür, nasazlıqlar zamanı təkrarlanmanı qarşısını almaq üçün.

Kotlin-də tranzaksiya istehsalçısının başlanğıcı nümunəsi:

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"))
    // digər əməliyyatlar
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}