Skip to content

Commit b0d69e2

Browse files
committed
Fix format
1 parent d0d9f2e commit b0d69e2

File tree

4 files changed

+12
-4
lines changed

4 files changed

+12
-4
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,9 @@ public ApacheKafkaContainerCluster(String version, int brokersNum, int internalT
3030
}
3131
if (internalTopicsRf <= 0 || internalTopicsRf > brokersNum) {
3232
throw new IllegalArgumentException(
33-
"internalTopicsRf '" + internalTopicsRf + "' must be less than or equal to brokersNum and greater than 0"
33+
"internalTopicsRf '" +
34+
internalTopicsRf +
35+
"' must be less than or equal to brokersNum and greater than 0"
3436
);
3537
}
3638

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,9 @@ public ConfluentKafkaContainerCluster(String confluentPlatformVersion, int broke
3030
}
3131
if (internalTopicsRf <= 0 || internalTopicsRf > brokersNum) {
3232
throw new IllegalArgumentException(
33-
"internalTopicsRf '" + internalTopicsRf + "' must be less than or equal to brokersNum and greater than 0"
33+
"internalTopicsRf '" +
34+
internalTopicsRf +
35+
"' must be less than or equal to brokersNum and greater than 0"
3436
);
3537
}
3638

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,9 @@ public KafkaContainerCluster(String confluentPlatformVersion, int brokersNum, in
3636
}
3737
if (internalTopicsRf <= 0 || internalTopicsRf > brokersNum) {
3838
throw new IllegalArgumentException(
39-
"internalTopicsRf '" + internalTopicsRf + "' must be less than or equal to brokersNum and greater than 0"
39+
"internalTopicsRf '" +
40+
internalTopicsRf +
41+
"' must be less than or equal to brokersNum and greater than 0"
4042
);
4143
}
4244

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,9 @@ public KafkaContainerKraftCluster(String confluentPlatformVersion, int brokersNu
3030
}
3131
if (internalTopicsRf <= 0 || internalTopicsRf > brokersNum) {
3232
throw new IllegalArgumentException(
33-
"internalTopicsRf '" + internalTopicsRf + "' must be less than or equal to brokersNum and greater than 0"
33+
"internalTopicsRf '" +
34+
internalTopicsRf +
35+
"' must be less than or equal to brokersNum and greater than 0"
3436
);
3537
}
3638

0 commit comments

Comments
 (0)