From 9e420d83e4747008c6b2bceb3f99dbb1d72d9828 Mon Sep 17 00:00:00 2001 From: Sahil Palvia Date: Wed, 3 Oct 2018 08:46:34 -0700 Subject: [PATCH] Fixing issue with KinesisClientUtil class (#433) * Passing HttpClientBuilder to the client instead of HttpClient --- .../java/software/amazon/kinesis/common/KinesisClientUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/KinesisClientUtil.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/KinesisClientUtil.java index 37a169e2..634c9b01 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/KinesisClientUtil.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/KinesisClientUtil.java @@ -31,7 +31,7 @@ public class KinesisClientUtil { * @return */ public static KinesisAsyncClient createKinesisAsyncClient(KinesisAsyncClientBuilder clientBuilder) { - return clientBuilder.httpClient(NettyNioAsyncHttpClient.builder().maxConcurrency(Integer.MAX_VALUE).build()) + return clientBuilder.httpClientBuilder(NettyNioAsyncHttpClient.builder().maxConcurrency(Integer.MAX_VALUE)) .build(); } }