Fix Inskinesis Retry Wait Time (#26)

useinsider · Mar 29, 2024 · 6c5fad5 · 6c5fad5
1 parent 5f62e50
commit 6c5fad5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/inskinesis/inskinesis.go b/inskinesis/inskinesis.go
@@ -116,7 +116,7 @@ func NewKinesis(config Config) (StreamInterface, error) {
 		stopBatchChannel: make(chan bool, 10),
 
 		retryCount:    config.RetryCount,
-		retryWaitTime: 100 * time.Millisecond,
+		retryWaitTime: config.RetryWaitTime,
 
 		verbose: config.Verbose,
 	}