Added Transactional ID Resource Type for ACL operations (#1834)

--------- Co-authored-by: John "Preston" Mille <john@ews-network.net>
confluentinc · Oct 10, 2024 · e3e96ff · e3e96ff
1 parent b5c82b9
commit e3e96ff
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/src/confluent_kafka/admin/__init__.py b/src/confluent_kafka/admin/__init__.py
@@ -77,6 +77,7 @@
                      RESOURCE_TOPIC,
                      RESOURCE_GROUP,
                      RESOURCE_BROKER,
+                     RESOURCE_TRANSACTIONAL_ID,
                      OFFSET_INVALID)
 
 from confluent_kafka import \

diff --git a/src/confluent_kafka/admin/_resource.py b/src/confluent_kafka/admin/_resource.py
@@ -25,6 +25,7 @@ class ResourceType(Enum):
     TOPIC = _cimpl.RESOURCE_TOPIC  #: Topic resource. Resource name is topic name.
     GROUP = _cimpl.RESOURCE_GROUP  #: Group resource. Resource name is group.id.
     BROKER = _cimpl.RESOURCE_BROKER  #: Broker resource. Resource name is broker id.
+    TRANSACTIONAL_ID = _cimpl.RESOURCE_TRANSACTIONAL_ID  #: Transactional ID resource.
 
     def __lt__(self, other):
         if self.__class__ != other.__class__:

diff --git a/src/confluent_kafka/src/AdminTypes.c b/src/confluent_kafka/src/AdminTypes.c
@@ -524,6 +524,7 @@ static void AdminTypes_AddObjectsResourceType (PyObject *m) {
         PyModule_AddIntConstant(m, "RESOURCE_TOPIC", RD_KAFKA_RESOURCE_TOPIC);
         PyModule_AddIntConstant(m, "RESOURCE_GROUP", RD_KAFKA_RESOURCE_GROUP);
         PyModule_AddIntConstant(m, "RESOURCE_BROKER", RD_KAFKA_RESOURCE_BROKER);
+        PyModule_AddIntConstant(m, "RESOURCE_TRANSACTIONAL_ID", RD_KAFKA_RESOURCE_TRANSACTIONAL_ID);
 }
 
 static void AdminTypes_AddObjectsResourcePatternType (PyObject *m) {