XComp commented on PR #21247: URL: https://github.com/apache/flink/pull/21247#issuecomment-1306963927
I'm also wondering whether it would be reasonable to unify the Kafka test utilities (in a follow-up task). :thinking: multiple tests create their own admin client and deal with Kafka environments differently (`KafkaSourceTestEnv`, `KafkaTestEnvironmentImpl`, `KafkaTableTestBase`). It feels like we should have a JUnit5 Extension for that as well. We could also move the topic randomization in a single location at the end. WDYT? -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org