trompa opened a new pull request, #133: URL: https://github.com/apache/flink-connector-kafka/pull/133
FLINK-34470 introduced a new consumer.position call that was not wrapped by retryOnWakeUp, differently than the rest of calls ont he class. It was generating random WakeupExceptions on our production code for Flink19. Trivial code change. But I extracted this to a method so i could add a simple test for all the calls -- 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]
