From e7a0be5bd356c39e5bd91b2baad7b2bb5ad42f5b Mon Sep 17 00:00:00 2001 From: Praveen raj Mani Date: Tue, 24 Mar 2020 01:04:39 +0530 Subject: [PATCH] fix: throttling of events during their replay (#9188) --- pkg/event/target/store.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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: