aljoscha opened a new pull request #12747: URL: https://github.com/apache/flink/pull/12747
This is a backport of #12589 for Flink 1.10.x. Porting was simple, there were (almost) no incompatibilities in the code. The big question is whether to do a version bump from Kafka 2.2.x to 2.4.1 in a Flink 1.10.x release. I do think that this is a very critical bug to fix, though. The review and PR form for #12589 should hold for this PR. ---------------------------------------------------------------- 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]
