Qingsheng Ren created FLINK-25249:
-------------------------------------
Summary: Reimplement KafkaSourceTestEnv with KafkaContainer
Key: FLINK-25249
URL: https://issues.apache.org/jira/browse/FLINK-25249
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Affects Versions: 1.13.3, 1.14.0
Reporter: Qingsheng Ren
Fix For: 1.15.0
Currently {{KafkaSourceTestEnv}} is based on KafkaTestBase, which is quite
flaky (probably because of the {{{}NetworkFailureProxy{}}}) and complex. Using
KafkaContainer instead could simplify and stabilize test cases of
{{KafkaSource}}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
