This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 063cced3f550 CAMEL-26593: camel-kafka - run the ITs in 4 parallel
forks and drop the serials groups (#29494)
063cced3f550 is described below
commit 063cced3f550ea29897691817984ddc53bb47eda
Author: Aurélien Pupier <[email protected]>
AuthorDate: Mon Nov 9 22:46:30 2026 +0100
CAMEL-26593: camel-kafka - run the ITs in 4 parallel forks and drop the
serials groups (#29494)
Co-authored-by: IBM Bob 2.2.1
---
components/camel-kafka/pom.xml | 20 +++++++++-----------
...BreakOnFirstErrorOffUsingKafkaManualCommitIT.java | 3 ---
.../KafkaBreakOnFirstErrorReleaseResourcesIT.java | 1 -
.../KafkaBreakOnFirstErrorReplayOldMessagesIT.java | 3 ---
.../KafkaBreakOnFirstErrorSeekIssueIT.java | 3 ---
...FirstErrorWithBatchUsingAsyncCommitManagerIT.java | 3 ---
...nFirstErrorWithBatchUsingKafkaManualCommitIT.java | 3 ---
...tErrorWithBatchUsingKafkaManualCommitRetryIT.java | 3 ---
...nFirstErrorWithBatchUsingSyncCommitManagerIT.java | 3 ---
.../kafka/integration/KafkaConsumerIdempotentIT.java | 3 ---
.../kafka/integration/KafkaExactlyOnceIT.java | 3 ---
.../integration/KafkaExactlyOnceRebalanceIT.java | 3 ---
.../integration/KafkaExactlyOnceRegressionIT.java | 3 ---
.../health/KafkaConsumerBadPortHealthCheckIT.java | 3 ---
...KafkaConsumerBadPortSupervisingHealthCheckIT.java | 3 ---
.../KafkaConsumerGroupProtocolHealthCheckIT.java | 3 ---
.../health/KafkaConsumerHealthCheckIT.java | 3 ---
.../KafkaConsumerUnresolvableHealthCheckIT.java | 3 ---
18 files changed, 9 insertions(+), 60 deletions(-)
diff --git a/components/camel-kafka/pom.xml b/components/camel-kafka/pom.xml
index ee03cf5f1722..30d69e84e08a 100644
--- a/components/camel-kafka/pom.xml
+++ b/components/camel-kafka/pom.xml
@@ -31,6 +31,14 @@
<name>Camel :: Kafka</name>
<description>Camel Kafka support</description>
+ <properties>
+ <!-- each fork starts its own Kafka container: it can be lowered with
-Dcamel.failsafe.forkCount=N on small machines -->
+ <camel.failsafe.forkCount>4</camel.failsafe.forkCount>
+ <!-- the ITs use less than 600 MB per fork: do not reserve the 3G of
the parent. Redefined entirely (and not
+ through additional-vmargs) to avoid having two -Xmx on the
command line -->
+ <camel.failsafe.fork.vmargs>-XX:+ExitOnOutOfMemoryError -Xmx1G
${camel.failsafe.fork.additional-vmargs}</camel.failsafe.fork.vmargs>
+ </properties>
+
<dependencies>
<!-- camel -->
@@ -197,6 +205,7 @@
<configuration>
<skipITs>${skipITs}</skipITs>
<skipTests>${skipTests}</skipTests>
+ <forkCount>${camel.failsafe.forkCount}</forkCount>
</configuration>
<executions>
<execution>
@@ -211,17 +220,6 @@
</goals>
<configuration>
<skipITs>${skipITs}</skipITs>
-
<excludedGroups>health,idempotent,breakOnFirstError</excludedGroups>
- </configuration>
- </execution>
- <execution>
- <id>serials-test</id>
- <goals>
- <goal>integration-test</goal>
- </goals>
- <configuration>
- <reuseForks>false</reuseForks>
-
<groups>health,idempotent,breakOnFirstError</groups>
<forkedProcessTimeoutInSeconds>1200</forkedProcessTimeoutInSeconds>
</configuration>
</execution>
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
index 28d5d63ba6f4..f500c5507aff 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
@@ -33,8 +33,6 @@ import org.apache.kafka.clients.producer.ProducerRecord;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -47,7 +45,6 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
* this will test basic breakOnFirstError functionality when it is turned off
and consumer uses allowManualCommit and
* KafkaManualCommit and NOOP Commit Manager
*/
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64" },
disabledReason = "This test does not run reliably on some
platforms")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
index 57fdd9e7f05a..28e6e3946ca0 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
@@ -47,7 +47,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
* heartbeat-threads, while reconnecting.
*
*/
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64" },
disabledReason = "This test does not run reliably on some
platforms")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
index 78c1ab6ba63b..1a41fef3b73e 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
@@ -38,8 +38,6 @@ import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
import org.junit.jupiter.api.condition.EnabledOnOs;
@@ -55,7 +53,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*
* mimics the reproduction of the problem in
https://github.com/CodeSmell/CamelKafkaOffset
*/
-@Tags({ @Tag("breakOnFirstError") })
@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
disabledReason = "Multiple problems: unreliable and
slow (see CAMEL-20680)")
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
index 82d1709d09f3..5fab9be68907 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
@@ -38,8 +38,6 @@ import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -55,7 +53,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*
* mimics the reproduction of the problem in
https://github.com/Krivda/camel-bug-reproduction
*/
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64", "ppc64le" },
disabledReason = "This test does not run reliably on some
platforms")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java
index 4f1af548ce67..8ee9c2e60b77 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsyncCommitManagerIT.java
@@ -35,8 +35,6 @@ import org.apache.kafka.common.Uuid;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -50,7 +48,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
* this will test basic breakOnFirstError functionality uses allowManualCommit
and set Sync Commit Manager this allows
* Camel to handle when to commit an offset
*/
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64", "ppc64le" },
disabledReason = "This test does not run reliably on some
platforms")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
index db0aee9867c0..f84f64744f70 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
@@ -33,8 +33,6 @@ import org.apache.kafka.clients.producer.ProducerRecord;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -47,7 +45,6 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
* this will test basic breakOnFirstError functionality uses allowManualCommit
and KafkaManualCommit because relying on
* Camel default to use NOOP Commit Manager this means the route
implementation MUST manage all offset commits
*/
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64" },
disabledReason = "This test does not run reliably on some
platforms")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
index e7464891096e..2a783c3bf3e4 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
@@ -33,8 +33,6 @@ import org.apache.kafka.clients.producer.ProducerRecord;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -51,7 +49,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*
* will demonstrate how to retry
*/
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64" },
disabledReason = "This test does not run reliably on some
platforms")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java
index 31cf7a07063d..367073c253ed 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java
@@ -33,8 +33,6 @@ import org.apache.kafka.clients.producer.ProducerRecord;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -47,7 +45,6 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
* this will test basic breakOnFirstError functionality uses allowManualCommit
and set Sync Commit Manager this allows
* Camel to handle when to commit an offset
*/
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64" },
disabledReason = "This test does not run reliably on some
platforms")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
index 3e979fa52c3e..204b3252e8c2 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
@@ -29,8 +29,6 @@ import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.DisplayName;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.Timeout;
import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
@@ -39,7 +37,6 @@ import static
org.apache.camel.component.kafka.serde.KafkaSerdeHelper.numericHea
@DisabledIfSystemProperty(named = "enable.kafka.consumer.idempotency.tests",
matches = "false")
@Timeout(60)
-@Tags({ @Tag("idempotent") })
public class KafkaConsumerIdempotentIT extends
KafkaConsumerIdempotentTestSupport {
private static final String TOPIC;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceIT.java
index 0ce64a65abe1..ed85c0aa11b0 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceIT.java
@@ -26,8 +26,6 @@ import org.apache.camel.CamelContext;
import org.apache.camel.builder.AggregationStrategies;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.kafka.KafkaConstants;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -46,7 +44,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
* <p>
* The scenarios cover transaction rollback and replay, error handling,
offsets, batching and route patterns.
*/
-@Tags({ @Tag("breakOnFirstError") })
class KafkaExactlyOnceIT extends KafkaExactlyOnceITSupport {
private static final Logger LOG =
LoggerFactory.getLogger(KafkaExactlyOnceIT.class);
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRebalanceIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRebalanceIT.java
index 226a5dd32695..5ce7ceecd509 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRebalanceIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRebalanceIT.java
@@ -41,8 +41,6 @@ import
org.apache.kafka.common.serialization.StringDeserializer;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -52,7 +50,6 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
/** Verifies stale group metadata is fenced when the consumer group rebalances
during processing. */
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64" },
disabledReason = "This test does not run reliably on some
platforms")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRegressionIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRegressionIT.java
index f287a953beff..188cb0d88aef 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRegressionIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRegressionIT.java
@@ -43,8 +43,6 @@ import org.awaitility.Awaitility;
import org.awaitility.core.ConditionTimeoutException;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledOnOs;
import org.junit.jupiter.api.condition.OS;
@@ -59,7 +57,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
* settings are rejected at route startup; supported routes are checked
against read_committed output and the actual
* committed source offsets in Kafka.
*/
-@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64" },
disabledReason = "This test does not run reliably on some
platforms")
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 64555b9baac1..f7453bfec99b 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
@@ -33,8 +33,6 @@ import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.MethodOrderer;
import org.junit.jupiter.api.Order;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
@@ -48,7 +46,6 @@ import static org.awaitility.Awaitility.await;
@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")
-@Tags({ @Tag("health") })
public class KafkaConsumerBadPortHealthCheckIT extends
KafkaHealthCheckTestSupport {
public static final String TOPIC = "test-health";
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 6f010f65eaa7..7970b5086dbc 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
@@ -35,8 +35,6 @@ import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.MethodOrderer;
import org.junit.jupiter.api.Order;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
@@ -50,7 +48,6 @@ import static org.awaitility.Awaitility.await;
@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")
-@Tags({ @Tag("health") })
public class KafkaConsumerBadPortSupervisingHealthCheckIT extends
KafkaHealthCheckTestSupport {
public static final String TOPIC = "test-health";
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerGroupProtocolHealthCheckIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerGroupProtocolHealthCheckIT.java
index 1ef43a285920..b22ec6321df9 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerGroupProtocolHealthCheckIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerGroupProtocolHealthCheckIT.java
@@ -36,8 +36,6 @@ import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.MethodOrderer;
import org.junit.jupiter.api.Order;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
@@ -56,7 +54,6 @@ import static org.awaitility.Awaitility.await;
@TestMethodOrder(MethodOrderer.OrderAnnotation.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")
-@Tags({ @Tag("health") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64", "s390x" },
disabledReason = "This test does not run reliably on ppc64le")
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java
index 6d46f6b25223..158611cb4977 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java
@@ -38,8 +38,6 @@ import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.MethodOrderer;
import org.junit.jupiter.api.Order;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
@@ -60,7 +58,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
@TestMethodOrder(MethodOrderer.OrderAnnotation.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")
-@Tags({ @Tag("health") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64", "s390x" },
disabledReason = "This test does not run reliably on ppc64le")
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 85285b3455f7..aff24b8c17dd 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
@@ -31,8 +31,6 @@ import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.MethodOrderer;
import org.junit.jupiter.api.Order;
-import org.junit.jupiter.api.Tag;
-import org.junit.jupiter.api.Tags;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
@@ -44,7 +42,6 @@ import static org.awaitility.Awaitility.await;
@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")
-@Tags({ @Tag("health") })
public class KafkaConsumerUnresolvableHealthCheckIT extends
KafkaHealthCheckTestSupport {
public static final String TOPIC = "test-health";
