[camel] branch main updated: (chores) camel-test-infra-kafka: use a common constant for the Kafka 3 image name

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new d4a2f0c  (chores) camel-test-infra-kafka: use a common constant for 
the Kafka 3 image name
d4a2f0c is described below

commit d4a2f0cb0fea7570b535666ee7c77c9822035075
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Thu Mar 24 11:31:26 2022 +0100

    (chores) camel-test-infra-kafka: use a common constant for the Kafka 3 
image name
---
 .../camel/test/infra/kafka/services/ContainerLocalKafkaService.java   | 4 +++-
 .../infra/kafka/services/ContainerLocalSingletonKafkaService.java     | 3 ++-
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/ContainerLocalKafkaService.java
 
b/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/ContainerLocalKafkaService.java
index bd3f00a..2aaa9e7 100644
--- 
a/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/ContainerLocalKafkaService.java
+++ 
b/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/ContainerLocalKafkaService.java
@@ -25,6 +25,8 @@ import org.testcontainers.containers.KafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
 public class ContainerLocalKafkaService implements KafkaService, 
ContainerService<KafkaContainer> {
+    public static final String KAFKA3_IMAGE_NAME = 
"confluentinc/cp-kafka:7.0.1";
+
     private static final Logger LOG = 
LoggerFactory.getLogger(ContainerLocalKafkaService.class);
     private final KafkaContainer kafka;
 
@@ -72,7 +74,7 @@ public class ContainerLocalKafkaService implements 
KafkaService, ContainerServic
     }
 
     public static ContainerLocalKafkaService kafka3Container() {
-        KafkaContainer container = new 
KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.0.1"));
+        KafkaContainer container = new 
KafkaContainer(DockerImageName.parse(KAFKA3_IMAGE_NAME));
         container = container.withEmbeddedZookeeper();
 
         return new ContainerLocalKafkaService(container);
diff --git 
a/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/ContainerLocalSingletonKafkaService.java
 
b/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/ContainerLocalSingletonKafkaService.java
index 3f27568..b3b1f09 100644
--- 
a/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/ContainerLocalSingletonKafkaService.java
+++ 
b/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/ContainerLocalSingletonKafkaService.java
@@ -52,7 +52,8 @@ public class ContainerLocalSingletonKafkaService extends 
ContainerLocalKafkaServ
 
     public static ContainerLocalSingletonKafkaService kafka3Container() {
         KafkaContainer container
-                = new 
KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.0.1")).withEmbeddedZookeeper();
+                = new 
KafkaContainer(DockerImageName.parse(ContainerLocalKafkaService.KAFKA3_IMAGE_NAME))
+                        .withEmbeddedZookeeper();
         return new ContainerLocalSingletonKafkaService(container);
     }
 }