From 9c42cb0e76a56dea5690d0dded94f325a63c5064 Mon Sep 17 00:00:00 2001 From: davidradl Date: Fri, 10 Oct 2025 14:41:59 +0100 Subject: [PATCH] http177 Add http 2 support Signed-off-by: davidradl --- CHANGELOG.md | 2 ++ README.md | 1 + .../http/internal/sink/httpclient/BatchRequestSubmitter.java | 2 +- .../http/internal/sink/httpclient/PerRequestSubmitter.java | 2 +- 4 files changed, 5 insertions(+), 2 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 04fb8e94..6ee55f9b 100644 --- a/CHANGELOG.md +++ b/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 diff --git a/README.md b/README.md index 019c07a8..ab9e72d8 100644 --- a/README.md +++ b/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. diff --git a/src/main/java/com/getindata/connectors/http/internal/sink/httpclient/BatchRequestSubmitter.java b/src/main/java/com/getindata/connectors/http/internal/sink/httpclient/BatchRequestSubmitter.java index 51652331..1287d44b 100644 --- a/src/main/java/com/getindata/connectors/http/internal/sink/httpclient/BatchRequestSubmitter.java +++ b/src/main/java/com/getindata/connectors/http/internal/sink/httpclient/BatchRequestSubmitter.java @@ -124,7 +124,7 @@ private HttpRequest buildHttpRequest(List 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); diff --git a/src/main/java/com/getindata/connectors/http/internal/sink/httpclient/PerRequestSubmitter.java b/src/main/java/com/getindata/connectors/http/internal/sink/httpclient/PerRequestSubmitter.java index 02b637c1..684f2b25 100644 --- a/src/main/java/com/getindata/connectors/http/internal/sink/httpclient/PerRequestSubmitter.java +++ b/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));