namespace with peer name

PeerDB-io · Sep 28, 2023 · b6d80d2 · b6d80d2
1 parent c57fb1f
commit b6d80d2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/eventhub/hubmanager.go b/flow/connectors/eventhub/hubmanager.go
@@ -122,7 +122,7 @@ func (m *EventHubManager) EnsureEventHubExists(ctx context.Context, peerName str
 	name := eventhub
 	_, err = hubClient.Get(ctx, resourceGroup, namespace, name, nil)
 
-	m.peerNames.Set(name, peerName)
+	m.peerNames.Set(fmt.Sprintf("%s.%s", peerName, eventhub), peerName)
 
 	// TODO (kaushik): make these configurable.
 	partitionCount := int64(3)