Kafka işlemleri kullanıldı mı (tam olarak bir kez semantiği)?

Evet, Apache Kafka, mesajların yazılması sırasında exactly-once semantics sağlayan işlemleri destekler. Bu, birden fazla kaydı tek bir atomik işlemde gruplayan işlemsel bir üretici kullanılarak gerçekleştirilir. Kotlin'de Kafka Üretici API'sini kullanarak, mesajların tamamen yazılmasını veya hiç yazılmamasını garantilemek ve arızalarda tekrarları önlemek için işlemleri yapılandırabilirsiniz.

Kotlin'de işlemsel bir üreticinin başlatılması örneği:

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"))
    // diğer işlemler
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}