dlg99 opened a new pull request #10498: URL: https://github.com/apache/pulsar/pull/10498
### Motivation Allow sink to rewind a topic to given offset and pause/resume consumer for given topic This is needed for https://github.com/apache/pulsar/pull/9927/ https://github.com/apache/pulsar/pull/9927/files#r595722189 ### Modifications SinkContext API: New methods to seek/pause/resume Matching implementations in ContextImpl Added ExtendedSourceContext interface (not public) to provide access to the PulsarSource's consumers. Updated ContextImpl and PulsarSource's implementations to provide this functionality. ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)* This change added tests and can be verified as follows: - Added unit tests ### Does this pull request potentially affect one of the following parts: *If `yes` was chosen, please highlight the changes* - The public API: yes SinkContext added new methods, default implementation provided. ### Documentation - Does this pull request introduce a new feature? yes - If yes, how is the feature documented? JavaDocs -- 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. For queries about this service, please contact Infrastructure at: [email protected]
