Shekharrajak opened a new issue, #711: URL: https://github.com/apache/doris-flink-connector/issues/711
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/incubator-doris/issues?q=is%3Aissue) and found no similar issues. ### Description Share groups enable processing concurrency beyond Kafka partition count. Acknowledgements must be coordinated with Doris commits and Flink checkpoints to support reliable recovery. How - Combine Doris data and Kafka share acknowledgements into one checkpointed committable. - After checkpoint completion, commit Doris first, then the Kafka acknowledgement transaction. - Preserve commit phase and transaction identities for retries and recovery. - Keep existing sink behavior as the default. - Add failure and recovery tests before claiming exactly-once guarantees. ### Solution _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
