From fd20bef46f5b311b4e8dc26c29418b53ad7672a8 Mon Sep 17 00:00:00 2001
From: Tilman Hausherr <tilman@apache.org>
Date: Tue, 14 Jan 2025 21:32:14 +0100
Subject: [PATCH] TIKA-4239: adjust call

---
 .../org/apache/tika/pipes/kafka/tests/TikaPipesKafkaTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tika-integration-tests/tika-pipes-kafka-integration-tests/src/test/java/org/apache/tika/pipes/kafka/tests/TikaPipesKafkaTest.java b/tika-integration-tests/tika-pipes-kafka-integration-tests/src/test/java/org/apache/tika/pipes/kafka/tests/TikaPipesKafkaTest.java
index fa70b82b6b..9c4c467419 100644
--- a/tika-integration-tests/tika-pipes-kafka-integration-tests/src/test/java/org/apache/tika/pipes/kafka/tests/TikaPipesKafkaTest.java
+++ b/tika-integration-tests/tika-pipes-kafka-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()) {