We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5ae9c49 commit 387ee16Copy full SHA for 387ee16
modules/kafka/src/main/java/org.testcontainers.containers/KafkaContainer.java
@@ -4,6 +4,10 @@
4
5
import java.util.stream.Stream;
6
7
+/**
8
+ * This container wraps Confluent Kafka and Zookeeper (optionally)
9
+ *
10
+ */
11
public class KafkaContainer extends GenericContainer<KafkaContainer> {
12
13
public static final int KAFKA_PORT = 9092;
@@ -79,4 +83,4 @@ public void start() {
79
83
public void stop() {
80
84
Stream.<Runnable>of(super::stop, proxy::stop).parallel().forEach(Runnable::run);
81
85
}
82
-}
86
+}
0 commit comments