code: def get_cluster_plan(self):
          
  
          _log.info('Fetching current cluster-topology from Zookeeper...')
          cluster_layout = self.get_topics(fetch_partition_state=False)
          # Re-format cluster-layout
          partitions = [
              {
                  'topic': topic_id,
                  'partition': int(p_id),
                  'replicas': partitions_data['replicas']
              }
              for topic_id, topic_info in six.iteritems(cluster_layout)
              for p_id, partitions_data in six.iteritems(topic_info['partitions'])
          ]
          return {
              'version': 1,
              'partitions': partitions
          }
docs: Fetch cluster plan from zookeeper.