From 0de50797b56218bdbec76702e2720834e8acbeca Mon Sep 17 00:00:00 2001 From: Tim Fox Date: Mon, 13 Jul 2020 11:43:19 +0100 Subject: [PATCH] Upgrade to Vert.x 3.9.1 which depends on version of Netty which allows backported ALPN in JDK 1.8.0_252 to be used, and provide warning if openSSL is not installed --- .../src/main/java/io/confluent/ksql/api/server/Server.java | 5 +++++ pom.xml | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/ksqldb-rest-app/src/main/java/io/confluent/ksql/api/server/Server.java b/ksqldb-rest-app/src/main/java/io/confluent/ksql/api/server/Server.java index 59e50ac7dbe3..335627c4cd06 100644 --- a/ksqldb-rest-app/src/main/java/io/confluent/ksql/api/server/Server.java +++ b/ksqldb-rest-app/src/main/java/io/confluent/ksql/api/server/Server.java @@ -28,6 +28,7 @@ import io.confluent.ksql.security.KsqlSecurityExtension; import io.confluent.ksql.util.KsqlException; import io.confluent.ksql.util.VertxCompletableFuture; +import io.netty.handler.ssl.OpenSsl; import io.vertx.core.Vertx; import io.vertx.core.WorkerExecutor; import io.vertx.core.http.ClientAuth; @@ -92,6 +93,10 @@ public Server(final Vertx vertx, final KsqlRestConfig config, final Endpoints en this.authenticationPlugin = Objects.requireNonNull(authenticationPlugin); this.serverState = Objects.requireNonNull(serverState); this.maxPushQueryCount = config.getInt(KsqlRestConfig.MAX_PUSH_QUERIES); + if (!OpenSsl.isAvailable()) { + log.warn("OpenSSL does not appear to be installed. ksqlDB will fall back to using the JDK " + + "TLS implementation. OpenSSL is recommended for better performance."); + } } public synchronized void start() { diff --git a/pom.xml b/pom.xml index 0f8388303bd1..552db9563df4 100644 --- a/pom.xml +++ b/pom.xml @@ -121,7 +121,7 @@ 2.24.0 2.9.5 67.1 - 3.9.0 + 3.9.1 1.0.3 true true