From b3a6703a5960eaec31513860cd2c8cc87302c457 Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Thu, 29 Dec 2022 18:47:26 -0800 Subject: [PATCH] chore: Enable HA PROXY protocol in vert.x --- .../src/main/java/io/confluent/ksql/api/server/Server.java | 3 ++- .../java/io/confluent/ksql/rest/server/PreconditionServer.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) 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 75c5117b93e9..329ef79651fc 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 @@ -296,7 +296,8 @@ private static HttpServerOptions createHttpServerOptions(final KsqlRestConfig ks .setReusePort(true) .setIdleTimeout(idleTimeoutSeconds).setIdleTimeoutUnit(TimeUnit.SECONDS) .setPerMessageWebSocketCompressionSupported(true) - .setPerFrameWebSocketCompressionSupported(true); + .setPerFrameWebSocketCompressionSupported(true) + .setUseProxyProtocol(true); if (tls) { final String ksConfigName = isInternalListener diff --git a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/PreconditionServer.java b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/PreconditionServer.java index e54c195122f1..1664a5efee19 100644 --- a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/PreconditionServer.java +++ b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/PreconditionServer.java @@ -159,7 +159,8 @@ private static HttpServerOptions createHttpServerOptions( .setReusePort(true) .setIdleTimeout(idleTimeoutSeconds).setIdleTimeoutUnit(TimeUnit.SECONDS) .setPerMessageWebSocketCompressionSupported(true) - .setPerFrameWebSocketCompressionSupported(true); + .setPerFrameWebSocketCompressionSupported(true) + .setUseProxyProtocol(true); if (tls) { final String ksConfigName = KsqlRestConfig.KSQL_SSL_KEYSTORE_ALIAS_EXTERNAL_CONFIG;