diff --git a/pykafka/exceptions.py b/pykafka/exceptions.py index 9c653b743..c4d583916 100644 --- 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) )