Do not use deprecated class

quarkus-qe · Nov 21, 2024 · 3ec861a · 3ec861a
1 parent a0eacb2
commit 3ec861a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java b/...main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java
@@ -3,6 +3,7 @@
 import org.apache.commons.lang3.StringUtils;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.KafkaContainer;
+import org.testcontainers.kafka.ConfluentKafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
 import io.quarkus.test.utils.DockerUtils;
@@ -20,7 +21,7 @@ public String getDisplayName() {
 
     @Override
     protected GenericContainer<?> initKafkaContainer() {
-        return new KafkaContainer(DockerImageName.parse(getKafkaImage() + ":" + getKafkaVersion()))
+        return new ConfluentKafkaContainer(DockerImageName.parse(getKafkaImage() + ":" + getKafkaVersion()))
                 .withCreateContainerCmdModifier(cmd -> cmd.withName(DockerUtils.generateDockerContainerName()));
     }