dalelane opened a new pull request, #293: URL: https://github.com/apache/flink-connector-kafka/pull/293
There are times when the offsets that Flink commits to Kafka are inaccurate, because offsets used by other things such as transaction markers are not considered. Some of these are represented in the tests in this commit. This doesn't result in any records being lost, as committed offsets are not used for restarts, however committed offsets are used by monitoring tools to understand Flink's progress so getting this wrong gives the appearance of record lag that isn't true. -- 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]
