slachiewicz commented on PR #279: URL: https://github.com/apache/flink-connector-kafka/pull/279#issuecomment-5243098900
Heads-up on three smaller PRs in flight against the same files, so whoever lands second knows to rebase: - #289 (approved) extracts the recovery-gating state out of `DynamicKafkaSourceEnumerator` into a new `ReaderRecoveryGate` class — most likely to collide with your +491/-46 in that file. - #291 changes when `DynamicKafkaSourceReader.handleSourceEvents` re-delivers no-more-splits; different hunk from yours, same method. - #285 is a two-line change in `DynamicKafkaSourceEnumeratorTest`. All three are small, so rebasing them onto this is likely easier than the reverse. -- 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]
