diff --git a/internal/protocol/http/fetcher.go b/internal/protocol/http/fetcher.go index 399ea01c2..75ada8408 100644 --- a/internal/protocol/http/fetcher.go +++ b/internal/protocol/http/fetcher.go @@ -171,8 +171,12 @@ func (f *Fetcher) Create(opts *base.Options) error { opts.Extra = &fhttp.OptsExtra{} } extra := opts.Extra.(*fhttp.OptsExtra) - if extra.Connections == 0 { + if extra.Connections <= 0 { extra.Connections = f.config.Connections + // Avoid zero connections configuration + if extra.Connections <= 0 { + extra.Connections = 1 + } } return nil }