Merge pull request #606 from fedinskiy/fix/full-image-names

Use fully-qualified image names
quarkus-qe · Oct 25, 2022 · cfd33c0 · cfd33c0
2 parents e054242 + 803cd23
commit cfd33c0
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/...main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java b/...main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java
@@ -20,7 +20,11 @@ public String getDisplayName() {
 
     @Override
     protected GenericContainer<?> initKafkaContainer() {
-        return new KafkaContainer(DockerImageName.parse(getKafkaImage() + ":" + getKafkaVersion()))
+        DockerImageName imageName = DockerImageName
+                .parse(getKafkaImage() + ":" + getKafkaVersion())
+                // todo https://github.com/testcontainers/testcontainers-java/issues/5612
+                .asCompatibleSubstituteFor("confluentinc/cp-kafka");
+        return new KafkaContainer(imageName)
                 .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("confluentinc/cp-schema-registry", "6.1.1", "/", 8081),
+    CONFLUENT("docker.io/confluentinc/cp-schema-registry", "6.1.1", "/", 8081),
     APICURIO("quay.io/apicurio/apicurio-registry-mem", "2.2.5.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("confluentinc/cp-kafka", "7.2.2", 9093, KafkaRegistry.CONFLUENT),
+    CONFLUENT("docker.io/confluentinc/cp-kafka", "7.2.2", 9093, KafkaRegistry.CONFLUENT),
     STRIMZI("quay.io/strimzi/kafka", "0.31.1-kafka-3.1.2", 9092, KafkaRegistry.APICURIO);
 
     private final String image;