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

fix isRetriableError (#159)

Browse source 
fix issues-158
This commit is contained in:
lrs 2024-09-17 03:27:23 +08:00 committed by GitHub
parent 8d10ac8dac
commit 43900507c9
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
consumer.go
View file

@ -299,10 +299,10 @@ func (c *Consumer) getShardIterator(ctx context.Context, streamName, shardID, se
}
func isRetriableError(err error) bool {
switch err.(type) {
case *types.ExpiredIteratorException:
if oe := (*types.ExpiredIteratorException)(nil); errors.As(err, &oe) {
return true
case *types.ProvisionedThroughputExceededException:
}
if oe := (*types.ProvisionedThroughputExceededException)(nil); errors.As(err, &oe) {
return true
}
return false