diff options
| author | Carson Ip <carsonip715@gmail.com> | 2019-10-25 16:41:07 +0800 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-11-08 05:21:16 -0800 |
| commit | 3861e16ea4ef8d60bc6ffc51c0183da33c629642 (patch) | |
| tree | e72741a5edf3eb2fe141fe2c37a2001f3797989b /kafka/conn.py | |
| parent | 736218da447cc97624d1f0838f1a15fefc24bd24 (diff) | |
| download | kafka-python-3861e16ea4ef8d60bc6ffc51c0183da33c629642.tar.gz | |
Fix typos
Diffstat (limited to 'kafka/conn.py')
| -rw-r--r-- | kafka/conn.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 815065b..bc01078 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -251,7 +251,7 @@ class BrokerConnection(object): self.config['send_buffer_bytes'])) assert self.config['security_protocol'] in self.SECURITY_PROTOCOLS, ( - 'security_protcol must be in ' + ', '.join(self.SECURITY_PROTOCOLS)) + 'security_protocol must be in ' + ', '.join(self.SECURITY_PROTOCOLS)) if self.config['security_protocol'] in ('SSL', 'SASL_SSL'): assert ssl_available, "Python wasn't built with SSL support" @@ -1196,7 +1196,7 @@ class BrokerConnection(object): # by looking at ApiVersionResponse api_versions = self._handle_api_version_response(f.value) version = self._infer_broker_version_from_api_versions(api_versions) - log.info('Broker version identifed as %s', '.'.join(map(str, version))) + log.info('Broker version identified as %s', '.'.join(map(str, version))) log.info('Set configuration api_version=%s to skip auto' ' check_version requests on startup', version) break |