diff --git a/client/internal/netflow/manager.go b/client/internal/netflow/manager.go index dbbe291cc..43d61b771 100644 --- a/client/internal/netflow/manager.go +++ b/client/internal/netflow/manager.go @@ -279,8 +279,12 @@ func (m *Manager) startRetries(ctx context.Context, flowConfigInterval time.Dura continue } if err := m.send(e); err != nil { - timer = time.NewTimer(retryBackoff.NextBackOff()) - resetBackoff = false + if nextBackoff := retryBackoff.NextBackOff(); nextBackoff != backoff.Stop { + timer = time.NewTimer(nextBackoff) + resetBackoff = false + } else { + resetBackoff = true // we exhausted retries, reset retry loop + } break } }