From 01e7d4167b4735fa63577b7b1a51d10f2e9f800a Mon Sep 17 00:00:00 2001 From: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com> Date: Fri, 20 Jan 2023 04:24:35 +0000 Subject: [PATCH] Do not retry forever by default Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com> --- pubsub/azure/eventhubs/eventhubs.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pubsub/azure/eventhubs/eventhubs.go b/pubsub/azure/eventhubs/eventhubs.go index 77272c0d8..088cc3ab4 100644 --- a/pubsub/azure/eventhubs/eventhubs.go +++ b/pubsub/azure/eventhubs/eventhubs.go @@ -105,7 +105,10 @@ func (aeh *AzureEventHubs) Init(metadata pubsub.Metadata) error { } } - // Default retry configuration is used if no backOff properties are set. + // Default retry configuration is used if no backOff properties are set + // backOff max retry config is set to 3, which means 3 retries by default + aeh.backOffConfig = retry.DefaultConfig() + aeh.backOffConfig.MaxRetries = 3 err = retry.DecodeConfigWithPrefix(&aeh.backOffConfig, metadata.Properties, "backOff") if err != nil { return fmt.Errorf("failed to decode backoff configuration")