valid_acl_operations(int_val) to decode authorized_operations fields

Author: dpkp

kafka/admin/acl_resource.py

@@ -1,5 +1,4 @@
 from __future__ import absolute_import
-from kafka.errors import IllegalArgumentError
 
 # enum in stdlib as of py3.4
 try:
@@ -8,6 +7,9 @@
     # vendored backport module
     from kafka.vendor.enum34 import IntEnum
 
+from kafka.errors import IllegalArgumentError
+from kafka.util import from_32_bit_field
+
 
 class ResourceType(IntEnum):
     """Type of kafka resource to set ACL for
@@ -247,3 +249,7 @@ def validate(self):
             raise IllegalArgumentError(
                 "pattern_type cannot be {} on a concrete ResourcePattern".format(self.pattern_type.name)
             )
+
+
+def valid_acl_operations(int_val):
+     return set([ACLOperation(v) for v in from_32_bit_field(int_val) if v not in (0, 1, 2)])