You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/03/01 04:31:00 UTC

[jira] [Created] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

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)