[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776482#comment-17776482 ]
Tzu-Li (Gordon) Tai commented on FLINK-26409: --------------------------------------------- Perhaps the only value that test gives us is "tests as proof/documentation" that the Kafka Source connector can continue to run as is in case of broker failures in a multi-broker setup. However, this does seem to be completely irrelevant to the connector code. > 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 > Assignee: Tzu-Li (Gordon) Tai > Priority: Major > > {{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.10#820010)