Use short image names for Kafka Confluent

quarkus-qe · May 5, 2023 · 5db6250 · 5db6250
1 parent d102e9e
commit 5db6250
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 7 deletions.
diff --git a/...main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java b/...main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java
@@ -20,11 +20,7 @@ public String getDisplayName() {
 
     @Override
     protected GenericContainer<?> initKafkaContainer() {
-        DockerImageName imageName = DockerImageName
-                .parse(getKafkaImage() + ":" + getKafkaVersion())
-                // todo https://github.com/testcontainers/testcontainers-java/issues/5612
-                .asCompatibleSubstituteFor("confluentinc/cp-kafka");
-        return new KafkaContainer(imageName)
+        return new KafkaContainer(DockerImageName.parse(getKafkaImage() + ":" + getKafkaVersion()))
                 .withCreateContainerCmdModifier(cmd -> cmd.withName(DockerUtils.generateDockerContainerName()));
     }
 

diff --git a/...-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaRegistry.java b/...-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaRegistry.java
@@ -1,7 +1,7 @@
 package io.quarkus.test.services.containers.model;
 
 public enum KafkaRegistry {
-    CONFLUENT("docker.io/confluentinc/cp-schema-registry", "7.3.3", "/", 8081),
+    CONFLUENT("confluentinc/cp-schema-registry", "7.3.3", "/", 8081),
     APICURIO("quay.io/apicurio/apicurio-registry-mem", "2.4.2.Final", "/apis", 8080);
 
     private final String image;

diff --git a/...st-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaVendor.java b/...st-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaVendor.java
@@ -1,7 +1,7 @@
 package io.quarkus.test.services.containers.model;
 
 public enum KafkaVendor {
-    CONFLUENT("docker.io/confluentinc/cp-kafka", "7.3.3", 9093, KafkaRegistry.CONFLUENT),
+    CONFLUENT("confluentinc/cp-kafka", "7.3.3", 9093, KafkaRegistry.CONFLUENT),
     STRIMZI("quay.io/strimzi/kafka", "0.34.0-kafka-3.4.0", 9092, KafkaRegistry.APICURIO);
 
     private final String image;