HTTP-177 Add HTTP 2 support

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## [Unreleased]
 
+- Added http 2 support.
+
 ## [0.22.0] - 2025-10-03
 
 -   Added ability to continue on error, introducing new metadata columns and new configuration option

README.md

@@ -12,6 +12,7 @@ The goal for HTTP TableLookup connector was to use it in Flink SQL statement as
 
 Currently, HTTP source connector supports only Lookup Joins (TableLookup) [1] in Table/SQL API.
 `HttpSink` supports both Streaming API (when using [HttpSink](src/main/java/com/getindata/connectors/http/internal/sink/HttpSink.java) built using [HttpSinkBuilder](src/main/java/com/getindata/connectors/http/internal/sink/HttpSinkBuilder.java)) and the Table API (using connector created in [HttpDynamicTableSinkFactory](src/main/java/com/getindata/connectors/http/internal/table/HttpDynamicTableSinkFactory.java)). 
+Note that the connector will work with both http 1.1 and http 2 endpoints.
 
 ## Updating the connector
 In case of updating http-connector please see [Breaking changes](#breaking-changes) section.

src/main/java/com/getindata/connectors/http/internal/sink/httpclient/BatchRequestSubmitter.java

@@ -124,7 +124,7 @@ private HttpRequest buildHttpRequest(List<HttpSinkRequestEntry> reqeustBatch, UR
             Builder requestBuilder = java.net.http.HttpRequest
                 .newBuilder()
                 .uri(endpointUri)
-                .version(Version.HTTP_1_1)
+                .version(Version.HTTP_2)
                 .timeout(Duration.ofSeconds(httpRequestTimeOutSeconds))
                 .method(method, publisher);
 

src/main/java/com/getindata/connectors/http/internal/sink/httpclient/PerRequestSubmitter.java

@@ -62,7 +62,7 @@ private HttpRequest buildHttpRequest(HttpSinkRequestEntry requestEntry, URI endp
         Builder requestBuilder = java.net.http.HttpRequest
             .newBuilder()
             .uri(endpointUri)
-            .version(Version.HTTP_1_1)
+            .version(Version.HTTP_2)
             .timeout(Duration.ofSeconds(httpRequestTimeOutSeconds))
             .method(requestEntry.method,
                 BodyPublishers.ofByteArray(requestEntry.element));