Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-26409

Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

    XMLWordPrintableJSON

Details

    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.

      Attachments

        Activity

          People

            tzulitai Tzu-Li (Gordon) Tai
            renqs Qingsheng Ren
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: