From efc57af43f90bd4643157863a5c0bc9ceb6bb2e2 Mon Sep 17 00:00:00 2001 From: Joshua Kim Date: Thu, 18 Feb 2021 05:29:15 -0800 Subject: [PATCH] Fixing bug where ShardFilter parameter for ListShards was being passed in for paginated calls. This resulted in a bug where all calls for ListShards when initializing the lease table would fail, since Kinesis only requires the NextToken parameter when making paginated calls. --- .../software/amazon/kinesis/leases/KinesisShardDetector.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/KinesisShardDetector.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/KinesisShardDetector.java index 96a0de6a..8baf61d2 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/KinesisShardDetector.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/KinesisShardDetector.java @@ -192,9 +192,9 @@ public class KinesisShardDetector implements ShardDetector { exceptionManager.add(ResourceInUseException.class, t -> t); exceptionManager.add(KinesisException.class, t -> t); - ListShardsRequest.Builder request = KinesisRequestsBuilder.listShardsRequestBuilder().shardFilter(shardFilter); + ListShardsRequest.Builder request = KinesisRequestsBuilder.listShardsRequestBuilder(); if (StringUtils.isEmpty(nextToken)) { - request = request.streamName(streamIdentifier.streamName()); + request = request.streamName(streamIdentifier.streamName()).shardFilter(shardFilter); } else { request = request.nextToken(nextToken); }