diff --git a/e2e/rbd.go b/e2e/rbd.go
index 4f866a545..00c4eeced 100644
--- a/e2e/rbd.go
+++ b/e2e/rbd.go
@@ -71,6 +71,7 @@ func createORDeleteRbdResouces(action string) {
 		e2elog.Failf("failed to read content from %s with error %v", rbdDirPath+rbdProvisioner, err)
 	}
 	data = oneReplicaDeployYaml(data)
+	data = enableTopologyInTemplate(data)
 	_, err = framework.RunKubectlInput(cephCSINamespace, data, action, ns, "-f", "-")
 	if err != nil {
 		e2elog.Failf("failed to %s rbd provisioner with error %v", action, err)
diff --git a/e2e/utils.go b/e2e/utils.go
index 8183f5f66..c45d07467 100644
--- a/e2e/utils.go
+++ b/e2e/utils.go
@@ -505,6 +505,10 @@ func oneReplicaDeployYaml(template string) string {
 	return re.ReplaceAllString(template, `$1 1`)
 }
 
+func enableTopologyInTemplate(data string) string {
+	return strings.ReplaceAll(data, "--feature-gates=Topology=false", "--feature-gates=Topology=true")
+}
+
 func validatePVCClone(sourcePvcPath, clonePvcPath, clonePvcAppPath string, f *framework.Framework) {
 	var wg sync.WaitGroup
 	totalCount := 10