summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorsharego <xw_cht.y@live.cn>2016-11-16 01:30:16 +0800
committerDana Powers <dana.powers@gmail.com>2016-11-15 09:30:16 -0800
commit57ea7e81dc00065825c1586af7fe3cc9609d1f6b (patch)
tree27e14a9480b938ffb0c81d831440c29492d938ed
parent43e0c38bf350eb38d3356de88f98308f7d408572 (diff)
downloadkafka-python-57ea7e81dc00065825c1586af7fe3cc9609d1f6b.tar.gz
typo (#883)
type error
-rw-r--r--kafka/conn.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index 5775af8..b451895 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -175,7 +175,7 @@ class BrokerConnection(object):
if self.config['security_protocol'] in ('SASL_PLAINTEXT', 'SASL_SSL'):
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':
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'