diff --git a/.travis/build.sh b/.travis/build.sh index cf6297d7..834e59df 100755 --- a/.travis/build.sh +++ b/.travis/build.sh @@ -55,7 +55,7 @@ if [ "$arch" == 's390x' ]; then mvn test-compile spotbugs:check -e -V -B -f testsuite set +e clearDockerEnv - mvn -e -V -B clean install -f testsuite -Pcustom -Dkafka.docker.image=quay.io/strimzi/kafka:0.33.2-kafka-3.4.0 + mvn -e -V -B clean install -f testsuite -Pcustom -Dkafka.docker.image=quay.io/strimzi/kafka:0.37.0-kafka-3.5.0 EXIT=$? exitIfError set -e @@ -64,6 +64,11 @@ elif [[ "$arch" != 'ppc64le' ]]; then set +e + clearDockerEnv + mvn -e -V -B clean install -f testsuite -Pkafka-3_5_0 + EXIT=$? + exitIfError + clearDockerEnv mvn -e -V -B clean install -f testsuite -Pkafka-3_4_0 EXIT=$? diff --git a/pom.xml b/pom.xml index 3ef50c4f..e343c777 100644 --- a/pom.xml +++ b/pom.xml @@ -103,7 +103,7 @@ 3.3.0 4.7.3 1.6.3 - 3.5.0 + 3.6.0 2.15.2 2.15.2 2.8.0 diff --git a/testsuite/common/src/main/java/io/strimzi/testsuite/oauth/common/TestUtil.java b/testsuite/common/src/main/java/io/strimzi/testsuite/oauth/common/TestUtil.java index a2764653..23473401 100644 --- a/testsuite/common/src/main/java/io/strimzi/testsuite/oauth/common/TestUtil.java +++ b/testsuite/common/src/main/java/io/strimzi/testsuite/oauth/common/TestUtil.java @@ -120,4 +120,12 @@ public static int countLogForRegex(List log, String regex) { } return count; } + + public static Throwable getRootCause(Throwable e) { + Throwable cause = e; + while (cause != null && cause.getCause() != null) { + cause = cause.getCause(); + } + return cause == e ? null : cause; + } } diff --git a/testsuite/keycloak-errors-tests/src/test/java/io/strimzi/testsuite/oauth/auth/ErrorReportingTests.java b/testsuite/keycloak-errors-tests/src/test/java/io/strimzi/testsuite/oauth/auth/ErrorReportingTests.java index 63c47b7d..620b9b1d 100644 --- a/testsuite/keycloak-errors-tests/src/test/java/io/strimzi/testsuite/oauth/auth/ErrorReportingTests.java +++ b/testsuite/keycloak-errors-tests/src/test/java/io/strimzi/testsuite/oauth/auth/ErrorReportingTests.java @@ -24,6 +24,7 @@ import static io.strimzi.testsuite.oauth.auth.Common.buildProducerConfigOAuthBearer; import static io.strimzi.testsuite.oauth.auth.Common.buildProducerConfigPlain; import static io.strimzi.testsuite.oauth.common.TestUtil.getContainerLogsForString; +import static io.strimzi.testsuite.oauth.common.TestUtil.getRootCause; public class ErrorReportingTests { @@ -463,7 +464,7 @@ private void cantConnectKeycloakWithTimeout() { } catch (Exception e) { long diff = System.currentTimeMillis() - start; Assert.assertTrue("is instanceof KafkaException", e instanceof KafkaException); - Assert.assertTrue("Failed due to LoginException", e.getCause().toString().contains("LoginException")); + Assert.assertTrue("Failed due to LoginException", getRootCause(e).toString().contains("LoginException")); Assert.assertTrue("Unexpected diff: " + diff, diff > timeout * 1000 && diff < timeout * 1000 + 1000); } } diff --git a/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/ConnectTimeoutTests.java b/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/ConnectTimeoutTests.java index 8e7db881..62f1ad5d 100644 --- a/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/ConnectTimeoutTests.java +++ b/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/ConnectTimeoutTests.java @@ -21,6 +21,7 @@ import static io.strimzi.testsuite.oauth.common.TestUtil.getContainerLogsForString; import static io.strimzi.testsuite.oauth.mockoauth.Common.buildProducerConfigOAuthBearer; import static io.strimzi.testsuite.oauth.mockoauth.Common.changeAuthServerMode; +import static io.strimzi.testsuite.oauth.common.TestUtil.getRootCause; public class ConnectTimeoutTests { @@ -98,7 +99,7 @@ private void connectAuthServerWithTimeout() throws Exception { } catch (Exception e) { long diff = System.currentTimeMillis() - start; Assert.assertTrue("is instanceof KafkaException", e instanceof KafkaException); - Assert.assertTrue("Failed due to LoginException", e.getCause().toString().contains("LoginException")); + Assert.assertTrue("Failed due to LoginException", getRootCause(e).toString().contains("LoginException")); Assert.assertTrue("Unexpected diff: " + diff, diff > timeoutOverride * 1000 && diff < timeoutOverride * 1000 + 1000); } finally { changeAuthServerMode("token", "mode_200"); diff --git a/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/JaasClientConfigTest.java b/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/JaasClientConfigTest.java index ad52a7a5..8576ce79 100644 --- a/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/JaasClientConfigTest.java +++ b/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/JaasClientConfigTest.java @@ -23,6 +23,8 @@ import java.util.Properties; import java.util.concurrent.ExecutionException; +import static io.strimzi.testsuite.oauth.common.TestUtil.getRootCause; + public class JaasClientConfigTest { @@ -305,7 +307,7 @@ private void assertConfigException(Throwable e, String message) { Throwable cause = e.getCause(); Assert.assertEquals("is a KafkaException", KafkaException.class, e.getClass()); - Throwable nestedCause = cause.getCause(); + Throwable nestedCause = getRootCause(cause); Assert.assertEquals("is a ConfigException", ConfigException.class, nestedCause.getClass()); Assert.assertTrue("Contains '" + message + "'", nestedCause.getMessage().contains(message)); } @@ -314,7 +316,7 @@ private void assertLoginException(Throwable e) { Throwable cause = e.getCause(); Assert.assertEquals("is a KafkaException", KafkaException.class, e.getClass()); - Throwable nestedCause = cause.getCause(); + Throwable nestedCause = getRootCause(cause); Assert.assertEquals("is a LoginException", LoginException.class, nestedCause.getClass()); } diff --git a/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/RetriesTests.java b/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/RetriesTests.java index 0ad21c72..41697659 100644 --- a/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/RetriesTests.java +++ b/testsuite/mockoauth-tests/src/test/java/io/strimzi/testsuite/oauth/mockoauth/RetriesTests.java @@ -23,6 +23,7 @@ import static io.strimzi.testsuite.oauth.mockoauth.Common.buildProducerConfigPlain; import static io.strimzi.testsuite.oauth.mockoauth.Common.changeAuthServerMode; import static io.strimzi.testsuite.oauth.mockoauth.Common.createOAuthClient; +import static io.strimzi.testsuite.oauth.common.TestUtil.getRootCause; import static io.strimzi.testsuite.oauth.mockoauth.Common.loginWithClientSecret; public class RetriesTests { @@ -123,7 +124,7 @@ private void testClientRetries() throws Exception { // get the exception Assert.assertTrue("is instanceof KafkaException", e instanceof KafkaException); - Assert.assertTrue("Failed due to LoginException", e.getCause().toString().contains("LoginException")); + Assert.assertTrue("Failed due to LoginException", getRootCause(e).toString().contains("LoginException")); } // repeat, it should succeed diff --git a/testsuite/pom.xml b/testsuite/pom.xml index dd3f792d..7025372f 100644 --- a/testsuite/pom.xml +++ b/testsuite/pom.xml @@ -48,7 +48,7 @@ 1.0.0-SNAPSHOT .. - quay.io/strimzi/kafka:0.35.1-kafka-3.4.0 + quay.io/strimzi/kafka:0.37.0-kafka-3.5.0 @@ -417,6 +417,13 @@ quay.io/strimzi/kafka:0.35.1-kafka-3.4.0 + + kafka-3_5_0 + + + quay.io/strimzi/kafka:0.37.0-kafka-3.5.0 + +