From 7939518d43f46945aac4a0a993dede937a503dd9 Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Wed, 13 Dec 2023 13:33:03 +0200 Subject: [PATCH] fix GetSourceConnectorsByStationAndPartition --- server/memphis_cloud.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/memphis_cloud.go b/server/memphis_cloud.go index b21ca9390..3753122ed 100644 --- a/server/memphis_cloud.go +++ b/server/memphis_cloud.go @@ -2601,8 +2601,8 @@ func deleteConnectorsTenantResources(tenantName string) error { return nil } -func (s *Server) GetSourceConnectorsByStationAndPartition(stationID, partitionNumber, numOfPartitions int) (map[string]interface{}, error) { - return map[string]interface{}{}, nil +func (s *Server) GetSourceConnectorsByStationAndPartition(stationID, partitionNumber, numOfPartitions int) ([]string, error) { + return []string{}, nil } func (ch ConsumersHandler) GetSinkConnectorsByStation(stationName StationName, station models.Station, partition int, partitions []int) ([]string, error) {