From c73f060abbf46f81ccc42798e5dc7e55bb3c65a2 Mon Sep 17 00:00:00 2001 From: Emmett Butler Date: Mon, 3 Apr 2017 08:52:27 -0700 Subject: [PATCH] support error code 29. related to #674 --- pykafka/exceptions.py | 8 ++++++++ 1 file changed, 8 insertions(+) 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) )