diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc
index 808ffc54c89..4083d570f14 100644
--- a/CHANGELOG.next.asciidoc
+++ b/CHANGELOG.next.asciidoc
@@ -50,6 +50,7 @@ https://github.com/elastic/beats/compare/v8.2.0\...main[Check the HEAD diff]
 - Fix namespacing on self-monitoring {pull}32336[32336]
 - Fix race condition when stopping runners {pull}32433[32433]
 - Fix concurrent map writes when system/process code called from reporter code {pull}32491[32491]
+- Log errors from the Elastic Agent V2 client errors channel. Avoids blocking when error occurs communicating with the Elastic Agent. {pull}34392[34392]
 
 *Auditbeat*
 
diff --git a/x-pack/libbeat/management/managerV2.go b/x-pack/libbeat/management/managerV2.go
index 7960e9240d2..f288954606b 100644
--- a/x-pack/libbeat/management/managerV2.go
+++ b/x-pack/libbeat/management/managerV2.go
@@ -44,6 +44,9 @@ type BeatV2Manager struct {
 
 	logger *logp.Logger
 
+	// handles client errors
+	errCanceller context.CancelFunc
+
 	// track individual units given to us by the V2 API
 	mx      sync.Mutex
 	units   map[unitKey]*client.Unit
@@ -175,11 +178,18 @@ func (cm *BeatV2Manager) Start() error {
 	if !cm.Enabled() {
 		return fmt.Errorf("V2 Manager is disabled")
 	}
-	err := cm.client.Start(context.Background())
+	if cm.errCanceller != nil {
+		cm.errCanceller()
+		cm.errCanceller = nil
+	}
+	ctx := context.Background()
+	err := cm.client.Start(ctx)
 	if err != nil {
 		return fmt.Errorf("error starting connection to client")
 	}
-
+	ctx, canceller := context.WithCancel(ctx)
+	cm.errCanceller = canceller
+	go cm.watchErrChan(ctx)
 	cm.client.RegisterDiagnosticHook("beat-rendered-config", "the rendered config used by the beat", "beat-rendered-config.yml", "application/yaml", cm.handleDebugYaml)
 	go cm.unitListen()
 	cm.isRunning = true
@@ -325,6 +335,17 @@ func (cm *BeatV2Manager) deleteUnit(unit *client.Unit) {
 // Private V2 implementation
 // ================================
 
+func (cm *BeatV2Manager) watchErrChan(ctx context.Context) {
+	for {
+		select {
+		case <-ctx.Done():
+			return
+		case err := <-cm.client.Errors():
+			cm.logger.Errorf("elastic-agent-client error: %s", err)
+		}
+	}
+}
+
 func (cm *BeatV2Manager) unitListen() {
 	const changeDebounce = 100 * time.Millisecond
 
@@ -405,6 +426,10 @@ func (cm *BeatV2Manager) stopBeat() {
 	}
 	cm.client.Stop()
 	cm.UpdateStatus(lbmanagement.Stopped, "Stopped")
+	if cm.errCanceller != nil {
+		cm.errCanceller()
+		cm.errCanceller = nil
+	}
 }
 
 func (cm *BeatV2Manager) reload(units map[unitKey]*client.Unit) {