Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
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