openstack/deb-python-kafka
Code Issues Proposed changes

Small style fixes in kafka.errors

Browse Source
This commit is contained in:
Dana Powers
2017-03-03 17:00:35 -08:00
parent 61eb396bba
commit ccbdf592c1
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
kafka/errors.py
View File

@@ -270,7 +270,8 @@ class InconsistentGroupProtocolError(BrokerResponseError):
errno = 23 errno = 23
message = 'INCONSISTENT_GROUP_PROTOCOL' message = 'INCONSISTENT_GROUP_PROTOCOL'
description = ('Returned in join group when the member provides a protocol' description = ('Returned in join group when the member provides a protocol'
' type or set of protocols which is not compatible with the current group.') ' type or set of protocols which is not compatible with the'
' current group.')
class InvalidGroupIdError(BrokerResponseError): class InvalidGroupIdError(BrokerResponseError):
@@ -333,19 +334,19 @@ class ClusterAuthorizationFailedError(BrokerResponseError):
class InvalidTimestampError(BrokerResponseError): class InvalidTimestampError(BrokerResponseError):
errno = 32 errno = 32
message = 'INVALID_TIMESTAMP' message = 'INVALID_TIMESTAMP'
description = ('The timestamp of the message is out of acceptable range.') description = 'The timestamp of the message is out of acceptable range.'
class UnsupportedSaslMechanismError(BrokerResponseError): class UnsupportedSaslMechanismError(BrokerResponseError):
errno = 33 errno = 33
message = 'UNSUPPORTED_SASL_MECHANISM' message = 'UNSUPPORTED_SASL_MECHANISM'
description = ('The broker does not support the requested SASL mechanism.') description = 'The broker does not support the requested SASL mechanism.'
class IllegalSaslStateError(BrokerResponseError): class IllegalSaslStateError(BrokerResponseError):
errno = 34 errno = 34
message = 'ILLEGAL_SASL_STATE' message = 'ILLEGAL_SASL_STATE'
description = ('Request is not valid given the current SASL state.') description = 'Request is not valid given the current SASL state.'
class KafkaUnavailableError(KafkaError): class KafkaUnavailableError(KafkaError):