TIKA-4326: adjust call

apache · Jan 14, 2025 · 8e3eb47 · 8e3eb47
1 parent 8ac9a52
commit 8e3eb47
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...integration-tests/src/test/java/org/apache/tika/pipes/kafka/tests/TikaPipesKafkaTest.java b/...integration-tests/src/test/java/org/apache/tika/pipes/kafka/tests/TikaPipesKafkaTest.java
@@ -93,7 +93,7 @@ public static void setUp() {
     private final File testFileFolder = new File("target", "test-files");
 
     private final Set<String> waitingFor = new HashSet<>();
-    KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1"));
+    KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1").asCompatibleSubstituteFor("apache/kafka"));
 
     private void createTestFiles() throws Exception {
         if (testFileFolder.mkdirs()) {