diff --git a/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java b/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java
index 25ddeedb4..3765206f0 100644
--- a/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/ConfluentKafkaContainerManagedResource.java
+++ b/quarkus-test-service-kafka/src/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/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaRegistry.java b/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaRegistry.java
index bef90dbc2..e0c08cb28 100644
--- a/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaRegistry.java
+++ b/quarkus-test-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/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaVendor.java b/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaVendor.java
index c7a743942..48f804ec6 100644
--- a/quarkus-test-service-kafka/src/main/java/io/quarkus/test/services/containers/model/KafkaVendor.java
+++ b/quarkus-test-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;