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)
Start main part of the wait script.