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 c43ab401d71 (chores) camel-kafka: stop enforcing a test lifecycle unless required c43ab401d71 is described below commit c43ab401d71370c7186508c2b6a25b54b57fb9f7 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Mon Aug 22 11:10:58 2022 +0200 (chores) camel-kafka: stop enforcing a test lifecycle unless required --- .../component/kafka/integration/BaseEmbeddedKafkaTestSupport.java | 2 -- .../component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java | 3 +-- .../apache/camel/component/kafka/integration/KafkaConsumerFullIT.java | 2 ++ .../camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java | 3 +-- .../component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java | 2 -- .../component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java | 2 -- .../component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java | 2 -- .../kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java | 3 +-- .../health/KafkaConsumerBadPortSupervisingHealthCheckIT.java | 3 +-- .../integration/health/KafkaConsumerUnresolvableHealthCheckIT.java | 3 +-- 10 files changed, 7 insertions(+), 18 deletions(-) diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/BaseEmbeddedKafkaTestSupport.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/BaseEmbeddedKafkaTestSupport.java index d044dc1b708..d0d76d5eb9d 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/BaseEmbeddedKafkaTestSupport.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/BaseEmbeddedKafkaTestSupport.java @@ -29,12 +29,10 @@ import org.apache.kafka.clients.admin.KafkaAdminClient; import org.apache.kafka.clients.producer.ProducerConfig; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; -import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.extension.RegisterExtension; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -@TestInstance(TestInstance.Lifecycle.PER_CLASS) public abstract class BaseEmbeddedKafkaTestSupport extends CamelTestSupport { // Note: you must use Strimzi on MacOS with Apple Silicon (and possibly other ARM-based architectures) @RegisterExtension diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java index 6b94fb6454a..9f01dfd3540 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java @@ -39,7 +39,6 @@ import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.MethodOrderer; import org.junit.jupiter.api.Order; import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.TestMethodOrder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -48,7 +47,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; @TestMethodOrder(MethodOrderer.OrderAnnotation.class) -@TestInstance(TestInstance.Lifecycle.PER_CLASS) + public class KafkaConsumerAsyncManualCommitIT extends BaseEmbeddedKafkaTestSupport { public static final String TOPIC = "testManualCommitTest"; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java index 14a194416d3..a5756b4a4e8 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java @@ -38,6 +38,7 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.MethodOrderer; import org.junit.jupiter.api.Order; import org.junit.jupiter.api.Test; +import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.TestMethodOrder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -48,6 +49,7 @@ import static org.junit.jupiter.api.Assertions.assertFalse; import static org.junit.jupiter.api.Assertions.assertTrue; @TestMethodOrder(MethodOrderer.OrderAnnotation.class) +@TestInstance(TestInstance.Lifecycle.PER_CLASS) public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport { public static final String TOPIC = "test-full"; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java index 81fd4f9d759..910d5820dfb 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java @@ -52,7 +52,6 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.MethodOrderer; import org.junit.jupiter.api.Order; import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.TestMethodOrder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -63,7 +62,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue; import static org.testcontainers.shaded.org.awaitility.Awaitility.await; @TestMethodOrder(MethodOrderer.OrderAnnotation.class) -@TestInstance(TestInstance.Lifecycle.PER_CLASS) + public class KafkaConsumerHealthCheckIT extends CamelTestSupport { public static final String TOPIC = "test-health"; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java index e88e4209b06..5387ba7d3e2 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java @@ -24,11 +24,9 @@ import org.apache.camel.component.kafka.consumer.KafkaManualCommit; import org.apache.camel.component.kafka.integration.BaseManualCommitTestSupport; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.RepeatedTest; -import org.junit.jupiter.api.TestInstance; import static org.junit.jupiter.api.Assertions.assertNotNull; -@TestInstance(TestInstance.Lifecycle.PER_METHOD) public class KafkaConsumerAsyncCommitIT extends BaseManualCommitTestSupport { public static final String TOPIC = "testManualAsyncCommitTest"; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java index fa5de350ff0..344e5b3f648 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java @@ -25,11 +25,9 @@ import org.apache.camel.component.kafka.integration.BaseManualCommitTestSupport; import org.apache.kafka.clients.producer.ProducerRecord; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.TestInstance; import static org.junit.jupiter.api.Assertions.assertNotNull; -@TestInstance(TestInstance.Lifecycle.PER_METHOD) public class KafkaConsumerNoopCommitIT extends BaseManualCommitTestSupport { public static final String TOPIC = "testManualNoopCommitTest"; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java index e9967641009..b6eb9f7791d 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java @@ -24,11 +24,9 @@ import org.apache.camel.component.kafka.consumer.KafkaManualCommit; import org.apache.camel.component.kafka.integration.BaseManualCommitTestSupport; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.RepeatedTest; -import org.junit.jupiter.api.TestInstance; import static org.junit.jupiter.api.Assertions.assertNotNull; -@TestInstance(TestInstance.Lifecycle.PER_METHOD) public class KafkaConsumerSyncCommitIT extends BaseManualCommitTestSupport { public static final String TOPIC = "testManualCommitSyncTest"; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java index a7a6703490e..c01ebcf9e7d 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java @@ -48,7 +48,6 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.MethodOrderer; import org.junit.jupiter.api.Order; import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.TestMethodOrder; import org.junit.jupiter.api.condition.DisabledIfSystemProperty; import org.junit.jupiter.api.extension.RegisterExtension; @@ -58,7 +57,7 @@ import org.slf4j.LoggerFactory; import static org.testcontainers.shaded.org.awaitility.Awaitility.await; @TestMethodOrder(MethodOrderer.OrderAnnotation.class) -@TestInstance(TestInstance.Lifecycle.PER_CLASS) + @DisabledIfSystemProperty(named = "kafka.instance.type", matches = "local-strimzi-container", disabledReason = "Test infra Kafka runs the Strimzi containers in a way that conflicts with multiple concurrent images") public class KafkaConsumerBadPortHealthCheckIT extends CamelTestSupport { diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java index 6e680b452e9..43783972e03 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java @@ -50,7 +50,6 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.MethodOrderer; import org.junit.jupiter.api.Order; import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.TestMethodOrder; import org.junit.jupiter.api.condition.DisabledIfSystemProperty; import org.junit.jupiter.api.extension.RegisterExtension; @@ -60,7 +59,7 @@ import org.slf4j.LoggerFactory; import static org.testcontainers.shaded.org.awaitility.Awaitility.await; @TestMethodOrder(MethodOrderer.OrderAnnotation.class) -@TestInstance(TestInstance.Lifecycle.PER_CLASS) + @DisabledIfSystemProperty(named = "kafka.instance.type", matches = "local-strimzi-container", disabledReason = "Test infra Kafka runs the Strimzi containers in a way that conflicts with multiple concurrent images") public class KafkaConsumerBadPortSupervisingHealthCheckIT extends CamelTestSupport { diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java index 1026131e4b2..1eb60997993 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java @@ -49,7 +49,6 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.MethodOrderer; import org.junit.jupiter.api.Order; import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.TestMethodOrder; import org.junit.jupiter.api.condition.DisabledIfSystemProperty; import org.slf4j.Logger; @@ -58,7 +57,7 @@ import org.slf4j.LoggerFactory; import static org.testcontainers.shaded.org.awaitility.Awaitility.await; @TestMethodOrder(MethodOrderer.OrderAnnotation.class) -@TestInstance(TestInstance.Lifecycle.PER_CLASS) + @DisabledIfSystemProperty(named = "kafka.instance.type", matches = "local-strimzi-container", disabledReason = "Test infra Kafka runs the Strimzi containers in a way that conflicts with multiple concurrent images") public class KafkaConsumerUnresolvableHealthCheckIT extends CamelTestSupport {