Skip to main content

acls

Creates, updates, deletes, gets or lists a acls resource.

Overview

Nameacls
TypeResource
Idconfluent.kafka.acls

Fields

NameDatatypeDescription
cluster_idstring
hoststring
kindstring
metadataobject
operationstring
pattern_typestring
permissionstring
principalstring
resource_namestring
resource_typestring

Methods

NameAccessible byRequired ParamsDescription
get_kafka_aclsSELECTcluster_idGenerally Available Return a list of ACLs that match the search criteria.
create_kafka_aclsINSERTcluster_id, data__host, data__operation, data__pattern_type, data__permission, data__principal, data__resource_name, data__resource_typeGenerally Available Create an ACL.
delete_kafka_aclsDELETEcluster_idGenerally Available Delete the ACLs that match the search criteria.
batch_create_kafka_aclsEXECcluster_idGenerally Available Create ACLs.

SELECT examples

Generally Available Return a list of ACLs that match the search criteria.

SELECT
cluster_id,
host,
kind,
metadata,
operation,
pattern_type,
permission,
principal,
resource_name,
resource_type
FROM confluent.kafka.acls
WHERE cluster_id = '{{ cluster_id }}';

INSERT example

Use the following StackQL query and manifest file to create a new acls resource.

/*+ create */
INSERT INTO confluent.kafka.acls (
data__resource_type,
data__resource_name,
data__pattern_type,
data__principal,
data__host,
data__operation,
data__permission,
cluster_id
)
SELECT
'{{ resource_type }}',
'{{ resource_name }}',
'{{ pattern_type }}',
'{{ principal }}',
'{{ host }}',
'{{ operation }}',
'{{ permission }}',
'{{ cluster_id }}'
;

DELETE example

Deletes the specified acls resource.

/*+ delete */
DELETE FROM confluent.kafka.acls
WHERE cluster_id = '{{ cluster_id }}';