Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.14.0, 1.13.3
Description
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
Attachments
Issue Links
- fixes
-
FLINK-23391 KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure
-
- Reopened
-
-
FLINK-20928 KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout
-
- Closed
-
- is depended upon by
-
FLINK-23956 KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"
-
- Closed
-
-
FLINK-16908 FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.
-
- Closed
-
-
FLINK-24119 KafkaITCase.testTimestamps fails due to "Topic xxx already exist"
-
- Closed
-
- links to