Allow developer to use system property to override default kafka image for embedded tests (#18739)
* Allow the kafka image to be swapped out via config if a developer needs/wants to
* Review suggestion follow up
diff --git a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/KafkaResource.java b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/KafkaResource.java
index 6a1d5ab..18e3c79 100644
--- a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/KafkaResource.java
+++ b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/KafkaResource.java
@@ -37,10 +37,19 @@
/**
* A Kafka container for use in embedded tests.
+ * <p>
+ * {@link #KAFKA_IMAGE} can be overriden via system property to use a different Kafka Docker image.
+ * </p>
*/
public class KafkaResource extends TestcontainerResource<KafkaContainer>
{
- private static final String KAFKA_IMAGE = "apache/kafka:4.0.0";
+ /**
+ * Kafka Docker image used in embedded tests. The image name is
+ * read from the system property {@code druid.testing.kafka.image} and
+ * defaults to {@code apache/kafka}. Environments that cannot run that
+ * image should set the system property to {@code apache/kafka-native}.
+ */
+ private static final String KAFKA_IMAGE = System.getProperty("druid.testing.kafka.image", "apache/kafka:4.0.0");
private EmbeddedDruidCluster cluster;
