From 6c5fad510dcac3d305bc8c271f20ee472f2a4ba7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Rafet=20Top=C3=A7u?= <44340673+rafet@users.noreply.github.com> Date: Fri, 29 Mar 2024 15:27:44 +0300 Subject: [PATCH] Fix Inskinesis Retry Wait Time (#26) --- inskinesis/inskinesis.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/inskinesis/inskinesis.go b/inskinesis/inskinesis.go index 48d0402..19ebec2 100644 --- 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, }