Kafka Tutorial | MySQL | Python- Exactly Once Processing in Kafka with MySQL
In this video we see how we can process exactly once the messages on Kafka. We use MySQL for database sink to store the latest offsets. We store the data and the offset in one transaction so we avoid duplicates in case of network error etc etc. Using omnipotent producers and consumers we achieve two things:
1)No data loss
2)No processing duplicates
The code can be found here: https://github.com/apostolos1927/Kafk...
Follow me on social media:
LinkedIn: www.linkedin.com/in/apostolos-athanasiou-9a0baa119
GitHub: https://github.com/apostolos1927/
00:00 - Intro
01:30 - Omnipotent producer in Kafka
04:20 - Python Producer
06:10 - Python Consumer & Consumer Rebalance Listener
20:57 - Demo with Custom Rebalance Listener
25:46 - Commit Offset Manually to Broker
31:09 - Conclusion