diff --git a/pkg/event/target/store.go b/pkg/event/target/store.go index 10a39a808..9f058efcb 100644 --- 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: