fix: Enables ALPN for internal requests when http2 and tls are in use (…

…#8094)

* fix: Enables ALPN for internal requests when http2 and tls are in use

ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/services/InternalKsqlClientFactory.java

@@ -30,7 +30,6 @@
 import java.util.Optional;
 import java.util.function.BiFunction;
 import java.util.function.Function;
-import java.util.function.Supplier;
 
 public final class InternalKsqlClientFactory {
 
@@ -60,9 +59,9 @@ public static KsqlClient createInternalClient(
 
   private static Function<Boolean, HttpClientOptions> httpOptionsFactory(
       final Map<String, String> clientProps, final boolean verifyHost,
-      final Supplier<HttpClientOptions> optionsSupplier) {
+      final Function<Boolean, HttpClientOptions> clientOptions) {
     return (tls) -> {
-      final HttpClientOptions httpClientOptions = optionsSupplier.get();
+      final HttpClientOptions httpClientOptions = clientOptions.apply(tls);
       if (!tls) {
         return httpClientOptions;
       }
@@ -89,11 +88,12 @@ private static Function<Boolean, HttpClientOptions> httpOptionsFactory(
     };
   }
 
-  private static HttpClientOptions createClientOptions() {
+  private static HttpClientOptions createClientOptions(final boolean tls) {
     return new HttpClientOptions().setMaxPoolSize(100);
   }
 
-  private static HttpClientOptions createClientOptionsHttp2() {
-    return new HttpClientOptions().setHttp2MaxPoolSize(100).setProtocolVersion(HttpVersion.HTTP_2);
+  private static HttpClientOptions createClientOptionsHttp2(final boolean tls) {
+    return new HttpClientOptions().setHttp2MaxPoolSize(100).setProtocolVersion(HttpVersion.HTTP_2)
+        .setUseAlpn(tls);
   }
 }