openstack/deb-python-kafka
Code Issues Proposed changes

fix unqualified references to exception types

Browse Source
This commit is contained in:
Lars Jørgen Solberg
2016-07-25 11:14:19 +00:00
committed by Dana Powers
parent f0082e42c2
commit 354e9a9c31
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/conn.py
View File

@@ -332,7 +332,7 @@ class BrokerConnection(object):
raise Errors.for_code(response.error_code)
if not self.config['sasl_mechanism'] in response.enabled_mechanisms:
raise AuthenticationMethodNotSupported(self.config['sasl_mechanism'] + " is not supported by broker")
raise Errors.AuthenticationMethodNotSupported(self.config['sasl_mechanism'] + " is not supported by broker")
return self._try_authenticate_plain()
@@ -368,7 +368,7 @@ class BrokerConnection(object):
buffer.write(data)
buffer.seek(0)
if not Int32.decode(buffer) == 0:
raise KafkaError('Expected a zero sized reply after sending credentials')
raise Errors.KafkaError('Expected a zero sized reply after sending credentials')
return True