fix GetSourceConnectorsByStationAndPartition

superstreamlabs · Dec 13, 2023 · 7939518 · 7939518
1 parent bfe7389
commit 7939518
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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) {