diff --git a/core/src/main/scala/kafka/zk/KafkaZkClient.scala b/core/src/main/scala/kafka/zk/KafkaZkClient.scala
index 713ed3014ea8d..424f4243d99d8 100644
--- a/core/src/main/scala/kafka/zk/KafkaZkClient.scala
+++ b/core/src/main/scala/kafka/zk/KafkaZkClient.scala
@@ -623,7 +623,7 @@ class KafkaZkClient private[zk] (zooKeeperClient: ZooKeeperClient,
    * @return sequence of topics in the cluster.
    *
    */
-  def getAllFederatedTopicsInNamespace(namespace: String, registerWatch: Boolean = false): Set[String] = {
+  def getAllFederatedTopicsInNamespace(namespace: String, registerWatch: Boolean = true): Set[String] = {
     val getChildrenResponse = retryRequestUntilConnected(
       if (paginateTopics) {
         debug(s"upgrading GetChildrenRequest to GetChildrenPaginatedRequest for " +