This repository contains code snippets in Scala, using the Java clients, that demonstrate how to use the Kafka 0.11 new APIs. The code is incomplete, and that's intended: the goal is to bring the focus on the new APIs only.
For more information, you can find the Kafka 0.11 release notes here: https://archive.apache.org/dist/kafka/0.11.0.0/RELEASE_NOTES.html
- Idempotent Producer
- Transactional Producer
- Transactional Consumer
- Exactly Once Low Level
- Kafka Admin Client
- Headers on Producer Record (new message type)
Kafka 0.11 has exactly once semantics support for Kafka Streams. To learn about it, I'd recommend my other repo:
https://github.com/simplesteph/kafka-streams-course
Feel free to do PR if you see something missing, or if there's a new feature I've missed, or you feel like re-writing things in Java. It's always appreciated