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

Fixing bug where ShardFilter parameter for ListShards was being passed in for paginated calls. (#790)

Browse source 
Co-authored-by: Joshua Kim <kimjos@amazon.com>
This commit is contained in:
Joshua Kim 2021-02-24 13:34:39 -08:00 committed by GitHub
parent b4f6f8fffb
commit a13ed13702
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/main/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java
View file

@ -315,13 +315,12 @@ public class KinesisProxy implements IKinesisProxyExtended {
request.setRequestCredentials(credentialsProvider.getCredentials()); request.setRequestCredentials(credentialsProvider.getCredentials());
if (StringUtils.isEmpty(nextToken)) { if (StringUtils.isEmpty(nextToken)) {
request.setStreamName(streamName); request.setStreamName(streamName);
request.setShardFilter(shardFilter);
} else { } else {
request.setNextToken(nextToken); request.setNextToken(nextToken);
} }
if (shardFilter != null) { LOG.info("Listing shards with list shards request " + request);
request.setShardFilter(shardFilter);
}
ListShardsResult result = null; ListShardsResult result = null;
LimitExceededException lastException = null; LimitExceededException lastException = null;