Quick rc to test an even shorter retry backoff

VERSION

@@ -1 +1 @@
-2.4.2-rc1
+2.4.2-rc2

cmd/constants.go

@@ -13,7 +13,7 @@ package cmd
 
 const (
 	// AppVersion is the current version of the app
-	AppVersion = "2.4.2-rc1"
+	AppVersion = "2.4.2-rc2"
 
 	// AppName is the name of the application to use in logging / places that require the artifact
 	AppName = "snowbridge"

pkg/target/kinesis.go

@@ -167,7 +167,7 @@ func (kt *KinesisTarget) process(messages []*models.Message) (*models.TargetWrit
 	nonThrottleFailures := make([]*models.Message, 0)
 	errorsEncountered := make([]error, 0)
 
-	retryDelay := 100 * time.Millisecond
+	retryDelay := 50 * time.Millisecond
 
 	for {
 		// We loop through until we have no throttle errors
@@ -243,7 +243,7 @@ func (kt *KinesisTarget) process(messages []*models.Message) (*models.TargetWrit
 
 			// Extend delay for next loop, to a maximum of 1s
 			if retryDelay < 1*time.Second {
-				retryDelay = retryDelay + 100*time.Millisecond
+				retryDelay = retryDelay + 50*time.Millisecond
 			}
 		} else {
 			// Break the loop and handle results if we have no throttles to retry