luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixing issue with KinesisClientUtil class (#433)

Browse source 
* Passing HttpClientBuilder to the client instead of HttpClient
This commit is contained in:
Sahil Palvia 2018-10-03 08:46:34 -07:00 committed by Justin Pfifer
parent e86bf3d7f3
commit 9e420d83e4
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/KinesisClientUtil.java
View file

@ -31,7 +31,7 @@ public class KinesisClientUtil {
* @return * @return
*/ */
public static KinesisAsyncClient createKinesisAsyncClient(KinesisAsyncClientBuilder clientBuilder) { 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(); .build();
} }
} }