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

Don't send StreamName when calling ListShards with NextToken. (#110)

Browse source 
Co-authored-by: Jason Pepper <jason.pepper@crypsisgroup.com>
This commit is contained in:
Jason Pepper 2020-03-20 00:45:53 -04:00 committed by GitHub
parent bc5c012fd3
commit dcd9d048fb
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
kinesis.go
View file

@ -27,8 +27,7 @@ func listShards(ksis kinesisiface.KinesisAPI, streamName string) ([]*kinesis.Sha
} }
listShardsInput = &kinesis.ListShardsInput{ listShardsInput = &kinesis.ListShardsInput{
NextToken: resp.NextToken, NextToken: resp.NextToken,
StreamName: aws.String(streamName),
} }
} }
} }