This is an automated email from the ASF dual-hosted git repository.
apupier 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 1743bfd2454f Disabling tests which are blocking the build in Kafka
Integration tests
1743bfd2454f is described below
commit 1743bfd2454f26d80800a9623858188ed3ae244a
Author: Aurélien Pupier <[email protected]>
AuthorDate: Wed Mar 11 16:48:20 2026 +0100
Disabling tests which are blocking the build in Kafka Integration tests
not found how to fix it so disabling them for now.
they are failing only with the strimzi image so they are still played on
Linux on CI.
it will allow to avoid the CI to be stucked on s390x and ppc64le, and
ensure remaining tests in the build are executed on these platforms
Signed-off-by: Aurélien Pupier <[email protected]>
---
.../component/kafka/integration/KafkaWithDBTransactionIT.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaWithDBTransactionIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaWithDBTransactionIT.java
index b1455023c02d..16d405cd9902 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaWithDBTransactionIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaWithDBTransactionIT.java
@@ -33,6 +33,7 @@ import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource;
import org.springframework.jdbc.core.JdbcTemplate;
@@ -163,9 +164,10 @@ public class KafkaWithDBTransactionIT extends
BaseKafkaTestSupport {
* With transaction - sends two duplicate messages, for the second one the
DB insert will fail and the rollback will
* take place. in this case the SQL operation is the last endpoint after
the message was sent to the kafka topic.
*/
- // @Test
@ParameterizedTest
@ValueSource(strings = { "transacted=true", "transactionalId=my-foo1",
"additionalProperties[transactional.id]=my-foo2" })
+ @DisabledIfSystemProperty(named = "kafka.instance.type", matches =
"local-strimzi-container",
+ disabledReason = "The test is blocked
indefinitely.")
public void transactionProducerWithDBLast(String txParam) throws Exception
{
String startEndpoint = "direct:startTxDBLast";
contextExtension.getContext().addRoutes(new RouteBuilder() {
@@ -200,8 +202,9 @@ public class KafkaWithDBTransactionIT extends
BaseKafkaTestSupport {
* With transaction - Uses multiple kafka producers to send duplicate
messages. One route with transacted=true and
* the other with no transactions.
*/
- // @Test
@Test
+ @DisabledIfSystemProperty(named = "kafka.instance.type", matches =
"local-strimzi-container",
+ disabledReason = "The test is blocked
indefinitely.")
public void transactionMultipleProducersWithDBLast() throws Exception {
contextExtension.getContext().addRoutes(new RouteBuilder() {
public void configure() {
@@ -263,6 +266,8 @@ public class KafkaWithDBTransactionIT extends
BaseKafkaTestSupport {
*/
@ParameterizedTest
@ValueSource(strings = { "transacted=true", "transactionalId=my-bar1",
"additionalProperties[transactional.id]=my-bar2" })
+ @DisabledIfSystemProperty(named = "kafka.instance.type", matches =
"local-strimzi-container",
+ disabledReason = "The test is blocked
indefinitely.")
public void transactionProducerWithDBFirst(String txParam) throws
Exception {
String startEndpoint = "direct:startTxDBFirst";
contextExtension.getContext().addRoutes(new RouteBuilder() {
