code: def test_create_describe_delete_acls(kafka_admin_client):
      """Tests that we can add, list and remove ACLs"""
  
      # Check that we don't have any ACLs in the cluster
      acls, error = kafka_admin_client.describe_acls(
          ACLFilter(
              principal=None,
              host="*",
              operation=ACLOperation.ANY,
              permission_type=ACLPermissionType.ANY,
              resource_pattern=ResourcePattern(
                  ResourceType.TOPIC, "topic"
              ),
          )
      )
  
      assert error is NoError
      assert len(acls) == 0
  
      # Try to add an ACL
      acl = ACL(
          principal="User:test",
          host="*",
          operation=ACLOperation.READ,
          permission_type=ACLPermissionType.ALLOW,
          resource_pattern=ResourcePattern(ResourceType.TOPIC, "topic"),
      )
      result = kafka_admin_client.create_acls([acl])
  
      assert len(result["failed"]) == 0
      assert len(result["succeeded"]) == 1
  
      # Check that we can list the ACL we created
      acl_filter = ACLFilter(
          principal=None,
          host="*",
          operation=ACLOperation.ANY,
          permission_type=ACLPermissionType.ANY,
          resource_pattern=ResourcePattern(ResourceType.TOPIC, "topic"),
      )
      acls, error = kafka_admin_client.describe_acls(acl_filter)
  
      assert error is NoError
      assert len(acls) == 1
  
      # Remove the ACL
      delete_results = kafka_admin_client.delete_acls(
          [
              ACLFilter(
                  principal="User:test",
                  host="*",
                  operation=ACLOperation.READ,
                  permission_type=ACLPermissionType.ALLOW,
                  resource_pattern=ResourcePattern(
                      ResourceType.TOPIC, "topic"
                  ),
              )
          ]
      )
  
      assert len(delete_results) == 1
      assert (
          len(delete_results[0][1]) == 1
      )  # Check number of affected ACLs
  
      # Make sure the ACL does not exist in the cluster anymore
      acls, error = kafka_admin_client.describe_acls(
          ACLFilter(
              principal="*",
              host="*",
              operation=ACLOperation.ANY,
              permission_type=ACLPermissionType.ANY,
              resource_pattern=ResourcePattern(
                  ResourceType.TOPIC, "topic"
              ),
          )
      )
  
      assert error is NoError
      assert len(acls) == 0
  
file_path: kafka-python/test/test_admin_integration.py
imports: import pytest
  from logging import info
  from test.testutil import env_kafka_version, random_string
  from threading import Event, Thread
  from time import time, sleep
  from kafka.admin import ACLFilter, ACLOperation, ACLPermissionType, ResourcePattern, ResourceType, ACL, ConfigResource, ConfigResourceType
  from kafka.errors import NoError, GroupCoordinatorNotAvailableError, NonEmptyGroupError, GroupIdNotFoundError
label_desc: Use image node_id 1 for calling a global function with example usage: test_create_describe_delete_acls(kafka_admin_client) without return types