async def make_admin(servers):
    return AIOKafkaAdminClient(bootstrap_servers=servers)
