fix: throttling of events during their replay (#9188)

5 years ago · e7a0be5bd3
parent ff932ca2a0
commit e7a0be5bd3
1 changed files with 2 additions and 1 deletions
--- a/pkg/event/target/store.go
+++ b/pkg/event/target/store.go
@ -112,9 +112,10 @@ func sendEvents(target event.Target, eventKeyCh <-chan string, doneCh <-chan str
 				loggerOnce(context.Background(),
 					fmt.Errorf("target.Send() failed with '%w'", err),
 					target.ID())
-				continue
 			}

+			// Retrying after 3secs back-off
+
 			select {
 			case <-retryTicker.C:
 			case <-doneCh: