diff --git a/pkg/consuldp/consul_dataplane.go b/pkg/consuldp/consul_dataplane.go index c49677b9..8830eb23 100644 --- a/pkg/consuldp/consul_dataplane.go +++ b/pkg/consuldp/consul_dataplane.go @@ -221,13 +221,12 @@ func (cdp *ConsulDataplane) Run(ctx context.Context) error { return err } - cdp.hcpTelemetry = telemetry.NewHCPExporter( + go telemetry.NewHCPExporter( cdp.resourceClient, cdp.logger.Named("hcp_telemetry"), fmt.Sprintf("%s:%d", cdp.cfg.Envoy.AdminBindAddress, cdp.cfg.Envoy.AdminBindPort), cdp.cfg.Proxy.ProxyID, - ) - go cdp.hcpTelemetry.Run(ctx) + ).Run(ctx) doneCh := make(chan error) go func() {