diff --git a/flow/connectors/eventhub/hubmanager.go b/flow/connectors/eventhub/hubmanager.go
index 9d75db7dd3..4c232b65f0 100644
--- a/flow/connectors/eventhub/hubmanager.go
+++ b/flow/connectors/eventhub/hubmanager.go
@@ -32,15 +32,18 @@ func NewEventHubManager(
 ) *EventHubManager {
 	hubs := cmap.New[*azeventhubs.ProducerClient]()
 	peerConfig := cmap.New[*protos.EventHubConfig]()
+	peerNames := cmap.New[string]()
 
 	for name, config := range groupConfig.Eventhubs {
 		peerConfig.Set(name, config)
 	}
 
 	return &EventHubManager{
-		ctx:   ctx,
-		creds: creds,
-		hubs:  hubs,
+		ctx:        ctx,
+		creds:      creds,
+		hubs:       hubs,
+		peerConfig: peerConfig,
+		peerNames:  peerNames,
 	}
 }