Fixed ZooKeeper service usage to delete /controller znode on migratio…

…n rollback (#10373) Signed-off-by: Paolo Patierno <[email protected]>
strimzi · Jul 24, 2024 · 36283d7 · 36283d7
1 parent 10e0c52
commit 36283d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ator/src/main/java/io/strimzi/operator/cluster/operator/assembly/ZooKeeperReconciler.java b/...ator/src/main/java/io/strimzi/operator/cluster/operator/assembly/ZooKeeperReconciler.java
@@ -898,7 +898,7 @@ protected Future<Void> maybeDeleteControllerZnode() {
      */
     protected Future<Void> deleteControllerZnode() {
         // migration rollback process ongoing
-        String zkConnectionString = KafkaResources.zookeeperServiceName(reconciliation.name()) + ":" + ZookeeperCluster.CLIENT_TLS_PORT;
+        String zkConnectionString = DnsNameGenerator.serviceDnsNameWithoutClusterDomain(reconciliation.namespace(), KafkaResources.zookeeperServiceName(reconciliation.name()))  + ":" + ZookeeperCluster.CLIENT_TLS_PORT;
         return KRaftMigrationUtils.deleteZooKeeperControllerZnode(
                 reconciliation,
                 vertx,