diff --git a/discovery/consul/consul.go b/discovery/consul/consul.go index e81749b1c..05eac61e8 100644 --- a/discovery/consul/consul.go +++ b/discovery/consul/consul.go @@ -197,7 +197,7 @@ func (cd *Discovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup) { } wctx, cancel := context.WithCancel(ctx) - srv.watch(wctx, ch) + go srv.watch(wctx, ch) services[name] = cancel }