Fix apache#3254 to re-enable KafkaSaslSslIT and KafkaSslIT native tests

zhfeng · Nov 2, 2021 · ef98f8a · ef98f8a
1 parent 0644b64
commit ef98f8a
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git a/...ests/kafka-sasl-ssl/src/test/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslSslIT.java b/...ests/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
@@ -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/...ests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslTestResource.java b/...ests/kafka-ssl/src/test/java/org/apache/camel/quarkus/kafka/ssl/KafkaSslTestResource.java
@@ -28,6 +28,7 @@
 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 Map<String, String> start() {
         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,