docs: def main():
      """Start main part of the wait script."""
      logger.info('Checking for available topics: %r', repr(REQUIRED_TOPICS))
  
      client = connect_kafka(hosts=KAFKA_HOSTS)
      check_topics(client, REQUIRED_TOPICS)