Skip to content

Commit 3a5b66f

Browse files
committed
chore: add missing network.close() for KafkaContainerCluster
1 parent 63189c8 commit 3a5b66f

File tree

4 files changed

+4
-0
lines changed

4 files changed

+4
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,5 +100,6 @@ public void start() {
100100
@Override
101101
public void stop() {
102102
this.brokers.stream().parallel().forEach(GenericContainer::stop);
103+
this.network.close();
103104
}
104105
}

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -101,5 +101,6 @@ public void start() {
101101
@Override
102102
public void stop() {
103103
this.brokers.stream().parallel().forEach(GenericContainer::stop);
104+
this.network.close();
104105
}
105106
}

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,5 +109,6 @@ public void start() {
109109
@Override
110110
public void stop() {
111111
allContainers().parallel().forEach(GenericContainer::stop);
112+
network.close();
112113
}
113114
}

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,5 +102,6 @@ public void start() {
102102
@Override
103103
public void stop() {
104104
this.brokers.stream().parallel().forEach(GenericContainer::stop);
105+
this.network.close();
105106
}
106107
}

0 commit comments

Comments
 (0)