support error code 29. related to #674

Parsely · Apr 3, 2017 · c73f060 · c73f060
1 parent ee33c5b
commit c73f060
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/pykafka/exceptions.py b/pykafka/exceptions.py
@@ -208,6 +208,13 @@ class RebalanceInProgress(ProtocolClientError):
     ERROR_CODE = 27
 
 
+class TopicAuthorizationFailed(ProtocolClientError):
+    """Returned by the broker when the client is not authorized to access the requested
+        topic.
+    """
+    ERROR_CODE = 29
+
+
 class GroupAuthorizationFailed(ProtocolClientError):
     """Returned by the broker when the client is not authorized to access a particular
     groupId.
@@ -235,6 +242,7 @@ class GroupAuthorizationFailed(ProtocolClientError):
                 UnknownMemberId,
                 InvalidSessionTimeout,
                 RebalanceInProgress,
+                TopicAuthorizationFailed,
                 GroupAuthorizationFailed)
 )