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

Merge pull request #20 from alexgridx/19-fix-retry-on-kinesis-error

Browse source 
#19 fixes retry on kinesis error
This commit is contained in:
Alex 2024-04-19 13:33:41 +02:00 committed by GitHub
commit c372167032
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
consumer.go
View file

@ -276,10 +276,12 @@ func (c *Consumer) getShardIterator(ctx context.Context, streamName, shardID, se
} }
func isRetriableError(err error) bool { func isRetriableError(err error) bool {
switch err.(type) { var expiredIteratorException *types.ExpiredIteratorException
case *types.ExpiredIteratorException: var provisionedThroughputExceededException *types.ProvisionedThroughputExceededException
switch {
case errors.As(err, &expiredIteratorException):
return true return true
case *types.ProvisionedThroughputExceededException: case errors.As(err, &provisionedThroughputExceededException):
return true return true
} }
return false return false