mxsm opened a new issue, #4795: URL: https://github.com/apache/eventmesh/issues/4795
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/eventmesh/issues?q=is%3Aissue) and found no similar issues. ### Enhancement Request https://github.com/apache/eventmesh/blob/291d748a0ed20ed724708d4cd3d8ff41afecb3f2/eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriterImpl.java#L85-L95 When flushing is in progress, a RuntimeException will be thrown if SourceWorker#commitOffsets method calls beginFlush. This error will propagate upwards causing the Source to exit. ### Describe the solution you'd like  replace this exception with log print and return false. > I hope you understand how offsets are managed. It's not just a simple replacement. ### 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]
