Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
kafka-3.0.0
-
None
Description
KafkaConsumerTestBase#runBrokerFailureTest is actually validating the functionality of Kafka broker and consumer (change partition leader when the ex-leader is down and let consumer switch to the new one without exception) instead of KafkaSource / FlinkKafkaConsumer, so we could consider removing this case.