Hello team,
In this discussion thread we will finalise the design for the KIP-1289 Support 
Hierarchical Transactional Acknowledgments for Share Groups. 

Share Groups currently support only immediate acknowledgement modes 
(IMPLICIT/EXPLICIT). This causes data loss in distributed streaming frameworks:

1. Worker acknowledges records → Records removed from Kafka
2. Checkpoint fails before sink write
3. Records lost (acknowledged but never persisted)

Goal: Enable exactly-once read semantics via transactional acknowledgements.
We already have similar pattern in Kafka producer transaction

KIP: KIP-1289 Support Hierarchical Transactional Acknowledgments for Share 
Groups - Apache Kafka - Apache Software Foundation 

Looking forward to community's feedback! 


Regards,Shekhar Prasad Rajak

Reply via email to