diff --git a/README.md b/README.md index dc74cca..de67b60 100644 --- a/README.md +++ b/README.md @@ -226,7 +226,7 @@ kafkaCluster.start(); StrimziKafkaCluster kafkaCluster = new StrimziKafkaCluster.StrimziKafkaClusterBuilder() .withNumberOfBrokers(3) .withKafkaVersion("3.8.0") // if not specified then latest Kafka version is selected - .withKraftEnabled() // if not specified ZK-based is used + .withKraft() // if not specified ZK-based is used .withAdditionalKafkaConfiguration(Map.of( "log.cleaner.enable", "false" )) diff --git a/src/main/java/io/strimzi/test/container/StrimziKafkaCluster.java b/src/main/java/io/strimzi/test/container/StrimziKafkaCluster.java index 659a7f0..8ae64f1 100644 --- a/src/main/java/io/strimzi/test/container/StrimziKafkaCluster.java +++ b/src/main/java/io/strimzi/test/container/StrimziKafkaCluster.java @@ -308,7 +308,7 @@ public StrimziKafkaClusterBuilder withKafkaVersion(String kafkaVersion) { return this; } - public StrimziKafkaClusterBuilder withKraftEnabled() { + public StrimziKafkaClusterBuilder withKraft() { this.enableKRaft = true; return this; } diff --git a/src/test/java/io/strimzi/test/container/StrimziKafkaKRaftClusterIT.java b/src/test/java/io/strimzi/test/container/StrimziKafkaKRaftClusterIT.java index 777a3b9..3ff3dd9 100644 --- a/src/test/java/io/strimzi/test/container/StrimziKafkaKRaftClusterIT.java +++ b/src/test/java/io/strimzi/test/container/StrimziKafkaKRaftClusterIT.java @@ -69,7 +69,7 @@ void testKafkaClusterStartupWithSharedNetwork() throws InterruptedException, Exe systemUnderTest = new StrimziKafkaCluster.StrimziKafkaClusterBuilder() .withNumberOfBrokers(NUMBER_OF_REPLICAS) .withSharedNetwork() - .withKraftEnabled() + .withKraft() .build(); systemUnderTest.start(); @@ -96,7 +96,7 @@ void testKafkaClusterWithSharedNetworkFunctionality() throws ExecutionException, systemUnderTest = new StrimziKafkaCluster.StrimziKafkaClusterBuilder() .withNumberOfBrokers(NUMBER_OF_REPLICAS) .withSharedNetwork() - .withKraftEnabled() + .withKraft() .build(); systemUnderTest.start(); @@ -120,7 +120,7 @@ void testStartClusterWithProxyContainer() { kafkaCluster = new StrimziKafkaCluster.StrimziKafkaClusterBuilder() .withNumberOfBrokers(NUMBER_OF_REPLICAS) .withProxyContainer(proxyContainer) - .withKraftEnabled() + .withKraft() .build(); kafkaCluster.start(); @@ -142,7 +142,7 @@ void testStartClusterWithProxyContainer() { private void setUpKafkaKRaftCluster() { systemUnderTest = new StrimziKafkaCluster.StrimziKafkaClusterBuilder() .withNumberOfBrokers(NUMBER_OF_REPLICAS) - .withKraftEnabled() + .withKraft() .build(); systemUnderTest.start(); }