You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/12/06 17:49:41 UTC
[camel] branch main updated: camel-test-infra-kafka: added support for CP 7 which should bring Kafka 3
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 f76370d camel-test-infra-kafka: added support for CP 7 which should bring Kafka 3
f76370d is described below
commit f76370d6dc87652910f48e7d802440fea9c2c3bd
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Mon Dec 6 15:23:40 2021 +0100
camel-test-infra-kafka: added support for CP 7 which should bring Kafka 3
---
.../infra/kafka/services/ContainerLocalKafkaService.java | 12 ++++++++++++
.../camel/test/infra/kafka/services/KafkaServiceFactory.java | 1 +
2 files changed, 13 insertions(+)
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 ef4f558..37fdd74 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
@@ -22,6 +22,7 @@ import org.apache.camel.test.infra.kafka.common.KafkaProperties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.containers.KafkaContainer;
+import org.testcontainers.utility.DockerImageName;
public class ContainerLocalKafkaService implements KafkaService, ContainerService<KafkaContainer> {
private static final Logger LOG = LoggerFactory.getLogger(ContainerLocalKafkaService.class);
@@ -65,4 +66,15 @@ public class ContainerLocalKafkaService implements KafkaService, ContainerServic
public KafkaContainer getContainer() {
return kafka;
}
+
+ public static ContainerLocalKafkaService kafka2Container() {
+ return new ContainerLocalKafkaService();
+ }
+
+ public static ContainerLocalKafkaService kafka3Container() {
+ KafkaContainer container = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.0.0"));
+ 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/KafkaServiceFactory.java b/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/KafkaServiceFactory.java
index deb02c2..ea237d6 100644
--- a/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/KafkaServiceFactory.java
+++ b/test-infra/camel-test-infra-kafka/src/test/java/org/apache/camel/test/infra/kafka/services/KafkaServiceFactory.java
@@ -33,6 +33,7 @@ public final class KafkaServiceFactory {
.addLocalMapping(ContainerLocalKafkaService::new)
.addMapping("local-strimzi-container", StrimziService::new)
.addRemoteMapping(RemoteKafkaService::new)
+ .addMapping("local-kafka3-container", ContainerLocalKafkaService::kafka3Container)
.build();
}
}