Skip to content

Commit c09611f

Browse files
committed
WIP: Increase http client's max chunk size
1 parent 7600c4a commit c09611f

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

ksqldb-rest-client/src/main/java/io/confluent/ksql/rest/client/KsqlRestClient.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,8 @@ public final class KsqlRestClient implements Closeable {
5656
static final String CCLOUD_CONNECT_USERNAME_HEADER = "X-Confluent-API-Key";
5757
static final String CCLOUD_CONNECT_PASSWORD_HEADER = "X-Confluent-API-Secret";
5858

59+
static final int CHUNK_SIZE = 16 * 1024;
60+
5961
private final KsqlClient client;
6062
private final LocalProperties localProperties;
6163
private final AtomicReference<String> serializedConsistencyVector;
@@ -113,8 +115,10 @@ public static KsqlRestClient create(
113115
creds,
114116
ccloudApiKey,
115117
(cprops, credz, lprops) -> new KsqlClient(cprops, credz, lprops,
116-
new HttpClientOptions(),
117-
Optional.of(new HttpClientOptions().setProtocolVersion(HttpVersion.HTTP_2)))
118+
new HttpClientOptions().setMaxChunkSize(CHUNK_SIZE),
119+
Optional.of(new HttpClientOptions()
120+
.setProtocolVersion(HttpVersion.HTTP_2)
121+
.setMaxChunkSize(CHUNK_SIZE)))
118122
);
119123
}
120124

0 commit comments

Comments
 (0)