diff --git a/ksql-cli/src/test/java/io/confluent/ksql/cli/BasicAuthFunctionalTest.java b/ksql-cli/src/test/java/io/confluent/ksql/cli/BasicAuthFunctionalTest.java index ffa054de2854..bb9ae1f02e64 100644 --- a/ksql-cli/src/test/java/io/confluent/ksql/cli/BasicAuthFunctionalTest.java +++ b/ksql-cli/src/test/java/io/confluent/ksql/cli/BasicAuthFunctionalTest.java @@ -34,8 +34,10 @@ import io.confluent.rest.RestConfig; import java.io.IOException; import java.net.URI; +import java.nio.charset.Charset; import java.nio.file.Files; import java.nio.file.Path; +import java.util.Base64; import java.util.Optional; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; @@ -53,7 +55,6 @@ import org.eclipse.jetty.websocket.api.annotations.WebSocket; import org.eclipse.jetty.websocket.client.ClientUpgradeRequest; import org.eclipse.jetty.websocket.client.WebSocketClient; -import org.glassfish.jersey.internal.util.Base64; import org.junit.ClassRule; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -203,7 +204,8 @@ private static Code extractStatusCode(final Throwable message) { } private static String buildBasicAuthHeader(final String userName, final String password) { - return Base64.encodeAsString(userName + ":" + password); + final String creds = userName + ":" + password; + return Base64.getEncoder().encodeToString(creds.getBytes(Charset.defaultCharset())); } private static String createJaasConfigContent() { diff --git a/ksql-engine/pom.xml b/ksql-engine/pom.xml index aa28d5345f7c..0d74d670bf22 100644 --- a/ksql-engine/pom.xml +++ b/ksql-engine/pom.xml @@ -168,6 +168,16 @@ test + + + org.eclipse.jetty + jetty-webapp + + ${jetty.version} + test + + diff --git a/ksql-rest-app/src/test/java/io/confluent/ksql/rest/integration/RestIntegrationTestUtil.java b/ksql-rest-app/src/test/java/io/confluent/ksql/rest/integration/RestIntegrationTestUtil.java index 6a34847250ee..59c1e0b0dadd 100644 --- a/ksql-rest-app/src/test/java/io/confluent/ksql/rest/integration/RestIntegrationTestUtil.java +++ b/ksql-rest-app/src/test/java/io/confluent/ksql/rest/integration/RestIntegrationTestUtil.java @@ -37,6 +37,8 @@ import io.confluent.ksql.test.util.secure.Credentials; import io.confluent.rest.validation.JacksonMessageBodyProvider; import java.net.URI; +import java.nio.charset.Charset; +import java.util.Base64; import java.util.Collections; import java.util.List; import java.util.Optional; @@ -49,7 +51,6 @@ import javax.ws.rs.core.Response; import org.eclipse.jetty.websocket.client.ClientUpgradeRequest; import org.eclipse.jetty.websocket.client.WebSocketClient; -import org.glassfish.jersey.internal.util.Base64; final class RestIntegrationTestUtil { @@ -232,7 +233,8 @@ static WebSocketClient makeWsRequest( } private static String buildBasicAuthHeader(final Credentials credentials) { - return Base64.encodeAsString(credentials.username + ":" + credentials.password); + final String creds = credentials.username + ":" + credentials.password; + return Base64.getEncoder().encodeToString(creds.getBytes(Charset.defaultCharset())); } private static String buildStreamingRequest(final String sql) { diff --git a/pom.xml b/pom.xml index 0f68de7ce63a..0b5e5de3f751 100644 --- a/pom.xml +++ b/pom.xml @@ -389,6 +389,13 @@ wiremock-jre8 ${wiremock.version} test + + + + org.eclipse.jetty + jetty-webapp + +