C0urante commented on pull request #11196: URL: https://github.com/apache/kafka/pull/11196#issuecomment-1068697326
It does look like we should consider clearing the message batch in `rewind` (or at least filtering out messages where a new topic partition has been requested by the task), but in practice this should only be an issue for tasks that manually manage their offsets via their `SourceTaskContext`. It's also unclear if an offset reset request should take precedence over a `RetriableException` since tasks do have full control over what they throw from `poll` and a `RetriableException` does indicate a request to retry the latest batch. -- 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]
