code: def setup(self, settings):
          '''
          Setup kafka
          '''
          KafkaBaseMonitor.setup(self, settings)
  
          self.zoo_client = KazooClient(hosts=settings['ZOOKEEPER_HOSTS'])
          self.zoo_client.start()
          self.path = settings['ZOOKEEPER_ASSIGN_PATH'] + settings['ZOOKEEPER_ID']
  
          if not self.zoo_client.exists(self.path):
              self.zoo_client.ensure_path(self.pathf setup(self, settings):
          '''
          Setup kafka
          '''
          KafkaBaseMonitor.setup(self, settings)
  
          self.zoo_client = KazooClient(hosts=settings['ZOOKEEPER_HOSTS'])
          self.zoo_client.start()
          self.path = settings['ZOOKEEPER_ASSIGN_PATH'] + settings['ZOOKEEPER_ID']
  
          if not self.zoo_client.exists(self.path):
              self.zoo_client.ensure_path(self.path)
docs: Setup kafka