Skip to content

Commit 16f037a

Browse files
fix parameter check in Kafka cluster examples
1 parent 7d83019 commit 16f037a

File tree

4 files changed

+15
-15
lines changed

4 files changed

+15
-15
lines changed

examples/kafka-cluster/src/test/java/com/example/kafkacluster/ApacheKafkaContainerCluster.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,12 +25,12 @@ public class ApacheKafkaContainerCluster implements Startable {
2525
private final Collection<KafkaContainer> brokers;
2626

2727
public ApacheKafkaContainerCluster(String version, int brokersNum, int internalTopicsRf) {
28-
if (brokersNum < 0) {
28+
if (brokersNum <= 0) {
2929
throw new IllegalArgumentException("brokersNum '" + brokersNum + "' must be greater than 0");
3030
}
31-
if (internalTopicsRf < 0 || internalTopicsRf > brokersNum) {
31+
if (internalTopicsRf <= 0 || internalTopicsRf > brokersNum) {
3232
throw new IllegalArgumentException(
33-
"internalTopicsRf '" + internalTopicsRf + "' must be less than brokersNum and greater than 0"
33+
"internalTopicsRf '" + internalTopicsRf + "' must be less than or equal to brokersNum and greater than 0"
3434
);
3535
}
3636

@@ -99,6 +99,6 @@ public void start() {
9999

100100
@Override
101101
public void stop() {
102-
this.brokers.stream().parallel().forEach(GenericContainer::stop);
102+
this.brokers.parallelStream().forEach(GenericContainer::stop);
103103
}
104104
}

examples/kafka-cluster/src/test/java/com/example/kafkacluster/ConfluentKafkaContainerCluster.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,12 +25,12 @@ public class ConfluentKafkaContainerCluster implements Startable {
2525
private final Collection<ConfluentKafkaContainer> brokers;
2626

2727
public ConfluentKafkaContainerCluster(String confluentPlatformVersion, int brokersNum, int internalTopicsRf) {
28-
if (brokersNum < 0) {
28+
if (brokersNum <= 0) {
2929
throw new IllegalArgumentException("brokersNum '" + brokersNum + "' must be greater than 0");
3030
}
31-
if (internalTopicsRf < 0 || internalTopicsRf > brokersNum) {
31+
if (internalTopicsRf <= 0 || internalTopicsRf > brokersNum) {
3232
throw new IllegalArgumentException(
33-
"internalTopicsRf '" + internalTopicsRf + "' must be less than brokersNum and greater than 0"
33+
"internalTopicsRf '" + internalTopicsRf + "' must be less than or equal to brokersNum and greater than 0"
3434
);
3535
}
3636

@@ -100,6 +100,6 @@ public void start() {
100100

101101
@Override
102102
public void stop() {
103-
this.brokers.stream().parallel().forEach(GenericContainer::stop);
103+
this.brokers.parallelStream().forEach(GenericContainer::stop);
104104
}
105105
}

examples/kafka-cluster/src/test/java/com/example/kafkacluster/KafkaContainerCluster.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,12 +31,12 @@ public class KafkaContainerCluster implements Startable {
3131
private final Collection<KafkaContainer> brokers;
3232

3333
public KafkaContainerCluster(String confluentPlatformVersion, int brokersNum, int internalTopicsRf) {
34-
if (brokersNum < 0) {
34+
if (brokersNum <= 0) {
3535
throw new IllegalArgumentException("brokersNum '" + brokersNum + "' must be greater than 0");
3636
}
37-
if (internalTopicsRf < 0 || internalTopicsRf > brokersNum) {
37+
if (internalTopicsRf <= 0 || internalTopicsRf > brokersNum) {
3838
throw new IllegalArgumentException(
39-
"internalTopicsRf '" + internalTopicsRf + "' must be less than brokersNum and greater than 0"
39+
"internalTopicsRf '" + internalTopicsRf + "' must be less than or equal to brokersNum and greater than 0"
4040
);
4141
}
4242

examples/kafka-cluster/src/test/java/com/example/kafkacluster/KafkaContainerKraftCluster.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,12 +25,12 @@ public class KafkaContainerKraftCluster implements Startable {
2525
private final Collection<KafkaContainer> brokers;
2626

2727
public KafkaContainerKraftCluster(String confluentPlatformVersion, int brokersNum, int internalTopicsRf) {
28-
if (brokersNum < 0) {
28+
if (brokersNum <= 0) {
2929
throw new IllegalArgumentException("brokersNum '" + brokersNum + "' must be greater than 0");
3030
}
31-
if (internalTopicsRf < 0 || internalTopicsRf > brokersNum) {
31+
if (internalTopicsRf <= 0 || internalTopicsRf > brokersNum) {
3232
throw new IllegalArgumentException(
33-
"internalTopicsRf '" + internalTopicsRf + "' must be less than brokersNum and greater than 0"
33+
"internalTopicsRf '" + internalTopicsRf + "' must be less than or equal to brokersNum and greater than 0"
3434
);
3535
}
3636

@@ -101,6 +101,6 @@ public void start() {
101101

102102
@Override
103103
public void stop() {
104-
this.brokers.stream().parallel().forEach(GenericContainer::stop);
104+
this.brokers.parallelStream().forEach(GenericContainer::stop);
105105
}
106106
}

0 commit comments

Comments
 (0)