openstack/deb-python-kafka
Code Issues Proposed changes

typo (#883)

Browse Source 
type error
This commit is contained in:
sharego
2016-11-16 01:30:16 +08:00
committed by Dana Powers
parent 43e0c38bf3
commit 57ea7e81dc
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

@@ -175,7 +175,7 @@ class BrokerConnection(object):
if self.config['security_protocol'] in ('SASL_PLAINTEXT', 'SASL_SSL'): if self.config['security_protocol'] in ('SASL_PLAINTEXT', 'SASL_SSL'):
assert self.config['sasl_mechanism'] in self.SASL_MECHANISMS, ( assert self.config['sasl_mechanism'] in self.SASL_MECHANISMS, (
'sasl_mechanism must be in ' + self.SASL_MECHANISMS) 'sasl_mechanism must be in ' + ', '.join(self.SASL_MECHANISMS))
if self.config['sasl_mechanism'] == 'PLAIN': if self.config['sasl_mechanism'] == 'PLAIN':
assert self.config['sasl_plain_username'] is not None, 'sasl_plain_username required for PLAIN sasl' assert self.config['sasl_plain_username'] is not None, 'sasl_plain_username required for PLAIN sasl'
assert self.config['sasl_plain_password'] is not None, 'sasl_plain_password required for PLAIN sasl' assert self.config['sasl_plain_password'] is not None, 'sasl_plain_password required for PLAIN sasl'