fix mapping of clients (#1343)

flow/connectors/eventhub/hubmanager.go

@@ -83,7 +83,7 @@ func (m *EventHubManager) GetOrCreateHubClient(ctx context.Context, name ScopedE
 
 	var hubConnectOK bool
 	var hub any
-	hub, hubConnectOK = m.hubs.Load(name.Eventhub)
+	hub, hubConnectOK = m.hubs.Load(name.ToString())
 	if hubConnectOK {
 		hubTmp := hub.(*azeventhubs.ProducerClient)
 		_, err := hubTmp.GetEventHubProperties(ctx, nil)
@@ -95,7 +95,7 @@ func (m *EventHubManager) GetOrCreateHubClient(ctx context.Context, name ScopedE
 			if closeError != nil {
 				slog.Error("failed to close producer client", slog.Any("error", closeError))
 			}
-			m.hubs.Delete(name.Eventhub)
+			m.hubs.Delete(name.ToString())
 			hubConnectOK = false
 		}
 	}
@@ -112,7 +112,7 @@ func (m *EventHubManager) GetOrCreateHubClient(ctx context.Context, name ScopedE
 		if err != nil {
 			return nil, fmt.Errorf("failed to create eventhub client: %v", err)
 		}
-		m.hubs.Store(name.Eventhub, hub)
+		m.hubs.Store(name.ToString(), hub)
 		return hub, nil
 	}
 

flow/connectors/eventhub/scoped_eventhub.go

@@ -47,5 +47,5 @@ func (s ScopedEventhub) Equals(other ScopedEventhub) bool {
 
 // ToString returns the string representation of the ScopedEventhub
 func (s ScopedEventhub) ToString() string {
-	return fmt.Sprintf("%s.%s.%s.%s", s.PeerName, s.Eventhub, s.PartitionKeyColumn, s.PartitionKeyValue)
+	return fmt.Sprintf("%s.%s", s.PeerName, s.Eventhub)
 }