This is an automated email from the ASF dual-hosted git repository.
capistrant pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new a54c55b3889 Allow developer to use system property to override default
kafka image for embedded tests (#18739)
a54c55b3889 is described below
commit a54c55b38894c4f9a85ee5e00d3a6c56fddd5859
Author: Lucas Capistrant <[email protected]>
AuthorDate: Thu Nov 13 10:46:00 2025 -0600
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
---
.../apache/druid/indexing/kafka/simulate/KafkaResource.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
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 6a1d5abe546..18e3c79503d 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 @@ import java.util.concurrent.ThreadLocalRandom;
/**
* 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;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
