Skip to content

Instantly share code, notes, and snippets.

@nehanarkhede

nehanarkhede/kafka-transactions.java

Last active March 13, 2022 10:06
Show Gist options
  • Star 2 You must be signed in to star a gist
  • Fork 1 You must be signed in to fork a gist
  • Save nehanarkhede/6dd6f482c2091f36d2d55bd027ca6fc0 to your computer and use it in GitHub Desktop.
Save nehanarkhede/6dd6f482c2091f36d2d55bd027ca6fc0 to your computer and use it in GitHub Desktop.
Download ZIP
Exactly-once guarantees and transactions in Apache Kafka
Raw
kafka-transactions.java
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