diff --git a/pkg/k8ssandra/util.go b/pkg/k8ssandra/util.go
index 28b492061..b8e38d723 100644
--- a/pkg/k8ssandra/util.go
+++ b/pkg/k8ssandra/util.go
@@ -1,14 +1,8 @@
 package k8ssandra
 
 import (
-	"context"
-
-	"github.com/go-logr/logr"
-	cassdcapi "github.com/k8ssandra/cass-operator/apis/cassandra/v1beta1"
 	api "github.com/k8ssandra/k8ssandra-operator/apis/k8ssandra/v1alpha1"
-	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/utils/strings/slices"
-	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
 func GetDatacenterForDecommission(kc *api.K8ssandraCluster) string {
@@ -35,27 +29,3 @@ func GetDatacenterForDecommission(kc *api.K8ssandraCluster) string {
 
 	return ""
 }
-
-func GetK8ssandraClusterFromCassDc(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter, client client.Client, logger logr.Logger) *api.K8ssandraCluster {
-	kcName := cassdc.Spec.ClusterName
-	if kcName == "" {
-		logger.Info("CassandraDatacenter %s/%s does not have a cluster name", cassdc.Namespace, cassdc.Name)
-		return nil
-	}
-
-	kcNamespace := cassdc.Labels[api.K8ssandraClusterNamespaceLabel]
-	if kcNamespace == "" {
-		logger.Info("CassandraDatacenter %s/%s does not have a k8ssandra cluster namespace label", cassdc.Namespace, cassdc.Name)
-		return nil
-	}
-
-	// Read the K8ssandraCluster object from the API server
-	kc := &api.K8ssandraCluster{}
-	err := client.Get(ctx, types.NamespacedName{Namespace: kcNamespace, Name: kcName}, kc)
-	if err != nil {
-		logger.Error(err, "Failed to get K8ssandraCluster")
-		return nil
-	}
-
-	return kc
-}