From c57fb1f0830c2b58e22fa59845886fb550c62668 Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Thu, 28 Sep 2023 14:19:28 -0400
Subject: [PATCH] fix npe

---
 flow/connectors/eventhub/hubmanager.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

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,
 	}
 }