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.

Browse source
This commit is contained in:
Joshua Kim 2021-02-23 08:07:15 -08:00
parent b4f6f8fffb
commit a0021c5328
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;