Skip to content

Instantly share code, notes, and snippets.

@nehanarkhede
Last active March 13, 2022 10:06
Show Gist options
  • Save nehanarkhede/6dd6f482c2091f36d2d55bd027ca6fc0 to your computer and use it in GitHub Desktop.
Save nehanarkhede/6dd6f482c2091f36d2d55bd027ca6fc0 to your computer and use it in GitHub Desktop.
Exactly-once guarantees and transactions in Apache Kafka
producer.initTransactions();
try {
producer.beginTransaction();
producer.send(record1);
producer.send(record2);
producer.commitTransaction();
} catch(ProducerFencedException e) {
producer.close();
} catch(KafkaException e) {
producer.abortTransaction();
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment