Qingsheng Ren created FLINK-26409: ------------------------------------- Summary: Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest Key: FLINK-26409 URL: https://issues.apache.org/jira/browse/FLINK-26409 Project: Flink Issue Type: Bug Components: Connectors / Kafka Reporter: Qingsheng Ren
{{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. -- This message was sent by Atlassian Jira (v8.20.1#820001)