Skip to content

Commit

Permalink
update to be more consistent
Browse files Browse the repository at this point in the history
Signed-off-by: see-quick <maros.orsak159@gmail.com>
  • Loading branch information
see-quick committed Oct 16, 2024
1 parent b6af8d0 commit 403b4c8
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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"
))
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -306,7 +306,7 @@ public StrimziKafkaClusterBuilder withKafkaVersion(String kafkaVersion) {
return this;
}

public StrimziKafkaClusterBuilder withKraftEnabled() {
public StrimziKafkaClusterBuilder withKraft() {
this.enableKRaft = true;
return this;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ void testKafkaClusterStartupWithSharedNetwork() throws InterruptedException, Exe
systemUnderTest = new StrimziKafkaCluster.StrimziKafkaClusterBuilder()
.withNumberOfBrokers(NUMBER_OF_REPLICAS)
.withSharedNetwork()
.withKraftEnabled()
.withKraft()
.build();
systemUnderTest.start();

Expand All @@ -96,7 +96,7 @@ void testKafkaClusterWithSharedNetworkFunctionality() throws ExecutionException,
systemUnderTest = new StrimziKafkaCluster.StrimziKafkaClusterBuilder()
.withNumberOfBrokers(NUMBER_OF_REPLICAS)
.withSharedNetwork()
.withKraftEnabled()
.withKraft()
.build();
systemUnderTest.start();

Expand All @@ -120,7 +120,7 @@ void testStartClusterWithProxyContainer() {
kafkaCluster = new StrimziKafkaCluster.StrimziKafkaClusterBuilder()
.withNumberOfBrokers(NUMBER_OF_REPLICAS)
.withProxyContainer(proxyContainer)
.withKraftEnabled()
.withKraft()
.build();

kafkaCluster.start();
Expand All @@ -142,7 +142,7 @@ void testStartClusterWithProxyContainer() {
private void setUpKafkaKRaftCluster() {
systemUnderTest = new StrimziKafkaCluster.StrimziKafkaClusterBuilder()
.withNumberOfBrokers(NUMBER_OF_REPLICAS)
.withKraftEnabled()
.withKraft()
.build();
systemUnderTest.start();
}
Expand Down

0 comments on commit 403b4c8

Please sign in to comment.