You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by zh...@apache.org on 2021/11/02 12:31:16 UTC
[camel-quarkus] branch main updated: Fix #3254 to re-enable
KafkaSaslSslIT and KafkaSslIT native tests (#3255)
This is an automated email from the ASF dual-hosted git repository.
zhfeng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/main by this push:
new 7bfd50f Fix #3254 to re-enable KafkaSaslSslIT and KafkaSslIT native tests (#3255)
7bfd50f is described below
commit 7bfd50f3eec20b3f6a02ee0d0caaa5cbf06ec0dd
Author: Amos Feng <zh...@gmail.com>
AuthorDate: Tue Nov 2 20:31:10 2021 +0800
Fix #3254 to re-enable KafkaSaslSslIT and KafkaSslIT native tests (#3255)
---
.../test/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslSslIT.java | 2 --
.../src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslIT.java | 2 --
.../java/org/apache/camel/quarkus/kafka/ssl/KafkaSslTestResource.java | 2 ++
3 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/integration-tests/kafka-sasl-ssl/src/test/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslSslIT.java b/integration-tests/kafka-sasl-ssl/src/test/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslSslIT.java
index 29dddaa..113d16c 100644
--- a/integration-tests/kafka-sasl-ssl/src/test/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslSslIT.java
+++ b/integration-tests/kafka-sasl-ssl/src/test/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslSslIT.java
@@ -17,9 +17,7 @@
package org.apache.camel.quarkus.kafka.sasl;
import io.quarkus.test.junit.NativeImageTest;
-import org.junit.jupiter.api.Disabled;
-@Disabled("https://github.com/apache/camel-quarkus/issues/2729")
@NativeImageTest
public class KafkaSaslSslIT extends KafkaSaslSslTest {
}
diff --git a/integration-tests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslIT.java b/integration-tests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslIT.java
index f8c539c..839cf6d 100644
--- a/integration-tests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslIT.java
+++ b/integration-tests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslIT.java
@@ -17,9 +17,7 @@
package org.apache.camel.quarkus.kafka.ssl;
import io.quarkus.test.junit.NativeImageTest;
-import org.junit.jupiter.api.Disabled;
-@Disabled("https://github.com/apache/camel-quarkus/issues/2729")
@NativeImageTest
public class KafkaSslIT extends KafkaSslTest {
}
diff --git a/integration-tests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslTestResource.java b/integration-tests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslTestResource.java
index 130b95a..ea775dd 100644
--- a/integration-tests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslTestResource.java
+++ b/integration-tests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslTestResource.java
@@ -28,6 +28,7 @@ import com.github.dockerjava.api.command.InspectContainerResponse;
import org.apache.camel.quarkus.test.support.kafka.KafkaTestResource;
import org.apache.camel.util.CollectionHelper;
import org.apache.commons.io.FileUtils;
+import org.apache.kafka.clients.CommonClientConfigs;
import org.testcontainers.containers.KafkaContainer;
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.images.builder.Transferable;
@@ -66,6 +67,7 @@ public class KafkaSslTestResource extends KafkaTestResource {
container.start();
return CollectionHelper.mapOf(
+ "kafka." + CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, container.getBootstrapServers(),
"camel.component.kafka.brokers", container.getBootstrapServers(),
"camel.component.kafka.security-protocol", "SSL",
"camel.component.kafka.ssl-key-password", KAFKA_KEYSTORE_PASSWORD,