This is an automated email from the ASF dual-hosted git repository. fmariani pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit b0dc7d0dbbf014db3453db37e63409dc8b57840c Author: Croway <[email protected]> AuthorDate: Tue Mar 31 15:15:25 2026 +0200 Increase netty test timeouts from 30s to 90s The embedded Kafka Connect runtime startup (worker, herder, REST server, connector initialization) takes significant time. 30-second timeouts were too tight and caused spurious failures. --- .../camel/kafkaconnector/nettyhttp/sink/CamelSinkNettyhttpITCase.java | 4 ++-- .../apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java | 4 ++-- .../camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/sink/CamelSinkNettyhttpITCase.java b/tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/sink/CamelSinkNettyhttpITCase.java index dc8675fd0c..cf54127bb8 100644 --- a/tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/sink/CamelSinkNettyhttpITCase.java +++ b/tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/sink/CamelSinkNettyhttpITCase.java @@ -82,7 +82,7 @@ public class CamelSinkNettyhttpITCase extends CamelSinkTestSupport { } @Test - @Timeout(30) + @Timeout(90) public void testBasicSendReceive() throws Exception { mockWebService.enqueueResponses(expect); ConnectorPropertyFactory connectorPropertyFactory = CamelNettyhttpPropertyFactory.basic() @@ -95,7 +95,7 @@ public class CamelSinkNettyhttpITCase extends CamelSinkTestSupport { } @Test - @Timeout(30) + @Timeout(90) public void testBasicSendReceiveUsingUrl() throws Exception { mockWebService.enqueueResponses(expect); ConnectorPropertyFactory connectorPropertyFactory = CamelNettyhttpPropertyFactory.basic() diff --git a/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java b/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java index f8288d3671..5c02e84a74 100644 --- a/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java +++ b/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java @@ -84,7 +84,7 @@ public class CamelSinkNettyITCase extends CamelSinkTestSupport { } @Test - @Timeout(30) + @Timeout(90) public void testBasicSendReceive() throws Exception { ConnectorPropertyFactory connectorPropertyFactory = CamelNettyPropertyFactory.basic() .withTopics(topicName) @@ -100,7 +100,7 @@ public class CamelSinkNettyITCase extends CamelSinkTestSupport { } @Test - @Timeout(30) + @Timeout(90) public void testBasicSendReceiveUsingUrl() throws Exception { ConnectorPropertyFactory connectorPropertyFactory = CamelNettyPropertyFactory.basic() .withTopics(topicName) diff --git a/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java b/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java index b84a91e65f..7c5347de11 100644 --- a/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java +++ b/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java @@ -74,7 +74,7 @@ public class CamelSourceNettyITCase extends CamelSourceTestSupport { } @Test - @Timeout(30) + @Timeout(90) public void testLaunchConnector() throws ExecutionException, InterruptedException { CamelNettyPropertyFactory connectorPropertyFactory = CamelNettyPropertyFactory .basic() @@ -89,7 +89,7 @@ public class CamelSourceNettyITCase extends CamelSourceTestSupport { } @Test - @Timeout(30) + @Timeout(90) public void testLaunchConnectorUsingUrl() throws ExecutionException, InterruptedException { CamelNettyPropertyFactory connectorPropertyFactory = CamelNettyPropertyFactory .basic()
