openstack/deb-python-kafka
Code Issues Proposed changes

fix calling for_code without referencing the Errors module

Browse Source
This commit is contained in:
Lars Jørgen Solberg
2016-07-25 09:31:06 +00:00
committed by Dana Powers
parent 2ebf9133ef
commit 2ce9eed23a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/conn.py
View File

@@ -329,7 +329,7 @@ class BrokerConnection(object):
response = self.recv() response = self.recv()
if not response.error_code is 0: if not response.error_code is 0:
raise for_code(response.error_code) raise Errors.for_code(response.error_code)
if not self.config['sasl_mechanism'] in response.enabled_mechanisms: if not self.config['sasl_mechanism'] in response.enabled_mechanisms:
raise AuthenticationMethodNotSupported(self.config['sasl_mechanism'] + " is not supported by broker") raise AuthenticationMethodNotSupported(self.config['sasl_mechanism'] + " is not supported by broker")