Vai tika izmantotas Kafka transakcijas (precīzi vienu reizi semantika)?

Jā, Apache Kafka atbalsta transakcijas, kas nodrošina precīzi vienu reizi (exactly-once) semantiku, ierakstot ziņojumus. Tas tiek panākts ar transakcijas ražotāja palīdzību, kas grupē vairākus ierakstus vienā atomā operācijā. Kotlin valodā, izmantojot Kafka Producer API, ir iespējams konfigurēt transakcijas, lai garantētu, ka ziņojumi vai ir pilnībā ierakstīti, vai vispār nav, novēršot dublēšanos kļūdu gadījumā.

Piemērs, kā inicializēt transakcijas ražotāju Kotlin valodā:

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"))
    // citas operācijas
    producer.commitTransaction()
} catch (e: Exception) {
    producer.abortTransaction()
}