diff --git a/kinesis.go b/kinesis.go index 490b73b..f63c2a7 100644 --- a/kinesis.go +++ b/kinesis.go @@ -27,8 +27,7 @@ func listShards(ksis kinesisiface.KinesisAPI, streamName string) ([]*kinesis.Sha } listShardsInput = &kinesis.ListShardsInput{ - NextToken: resp.NextToken, - StreamName: aws.String(streamName), + NextToken: resp.NextToken, } } }