Skip to content

Commit f914dd0

Browse files
committed
Fix format
1 parent d8f8b55 commit f914dd0

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,9 +48,7 @@ public ApacheKafkaContainerCluster(String version, int brokersNum, int internalT
4848
IntStream
4949
.range(0, brokersNum)
5050
.mapToObj(brokerNum -> {
51-
return new KafkaContainer(
52-
DockerImageName.parse("apache/kafka").withTag(version)
53-
)
51+
return new KafkaContainer(DockerImageName.parse("apache/kafka").withTag(version))
5452
.withNetwork(this.network)
5553
.withNetworkAliases("broker-" + brokerNum)
5654
.withEnv("CLUSTER_ID", clusterId)

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44
import org.awaitility.Awaitility;
55
import org.testcontainers.containers.Container;
66
import org.testcontainers.containers.GenericContainer;
7-
import org.testcontainers.kafka.ConfluentKafkaContainer;
87
import org.testcontainers.containers.Network;
8+
import org.testcontainers.kafka.ConfluentKafkaContainer;
99
import org.testcontainers.lifecycle.Startable;
1010
import org.testcontainers.utility.DockerImageName;
1111

0 commit comments

Comments
 (0)