Kafka транзакциялары колдонулду беле (такыр бир жолу семантика)?

Ооба, Apache Kafka колдойт транзакциялар, алар жазуу учурунда дәл-бир жолу (exactly-once) семантиканын камсыз кылат. Бул транзакциялык өндүрүүчү аркылуу ишке ашырылат, ал бир нече жазууларды бир атомдук операцияга топтогон. Kotlinде Kafka Producer API колдонуп, транзакцияларды конфигурациялап, билдирүүлөр толугу менен жазылганын же эч качан жазылбаганын камсыз кылса болот, ката кетирүүдө дублдуулукка жол бербөө үчүн.

Кotlinде транзакциялык өндүрүүчүнүн башталышынын мисалы:

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()
}