Skip to content
代码片段 群组 项目
未验证 提交 e1f82b8e 编辑于 作者: Lingnan Liu's avatar Lingnan Liu 提交者: GitHub
浏览文件

KAFKALESS-1254: Enable two tests in BrokerFailureDetectorTest (#7190)

上级 3b332771
No related branches found
No related tags found
无相关合并请求
......@@ -21,7 +21,6 @@ import org.apache.kafka.common.utils.Time;
import org.apache.kafka.test.NoRetryException;
import org.apache.kafka.test.TestUtils;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.TestInfo;
import org.junit.jupiter.params.ParameterizedTest;
......@@ -155,7 +154,6 @@ public class BrokerFailureDetectorTest extends DataBalancerClusterTestHarness {
* Number 1 is not true for KRaft, however we keep the same test behavior for KRaft for simplicity.
*/
@ParameterizedTest(name = TestUtils.TEST_WITH_PARAMETERIZED_QUORUM_NAME)
@Disabled // Disabled this test since we seem to have concurrency issues in BFD, tracking in KAFKALESS-1254
@ValueSource(strings = {"zk", "kraft"})
public void testPartialClusterFailure(String quorum) throws Exception {
assertTrue(anomalies.isEmpty());
......@@ -223,7 +221,7 @@ public class BrokerFailureDetectorTest extends DataBalancerClusterTestHarness {
}
@ParameterizedTest(name = TestUtils.TEST_WITH_PARAMETERIZED_QUORUM_NAME)
@ValueSource(strings = {"zk"}) // KRaft test is disabled due to KAFKALESS-1254
@ValueSource(strings = {"zk", "kraft"})
public void testLoadFailedBrokers(String quorum) throws InterruptedException, ExecutionException {
int brokerId = notControllerKafkaBroker().config().brokerId();
killBrokerById(brokerId);
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册