diff options
| author | tyronecai <tyronecai@163.com> | 2016-06-23 23:01:38 +0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-06-23 08:01:38 -0700 |
| commit | b2bc1f0ed7b339b111e02afec1d8b7aa1d8495da (patch) | |
| tree | 1b885080082d08bced944068d47e5c3145c2d241 | |
| parent | bb2a54116f714d7a13c1eae9975e0f3fdd6c02ed (diff) | |
| download | kafka-python-b2bc1f0ed7b339b111e02afec1d8b7aa1d8495da.tar.gz | |
assert will be disabled by "python -O" (#736)
| -rw-r--r-- | kafka/conn.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 005dd7e..25c1441 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -32,9 +32,9 @@ DEFAULT_KAFKA_PORT = 9092 # support older ssl libraries try: - assert ssl.SSLWantReadError - assert ssl.SSLWantWriteError - assert ssl.SSLZeroReturnError + ssl.SSLWantReadError + ssl.SSLWantWriteError + ssl.SSLZeroReturnError except: log.warning('old ssl module detected.' ' ssl error handling may not operate cleanly.' @@ -121,7 +121,7 @@ class BrokerConnection(object): socket.AF_UNSPEC, socket.SOCK_STREAM) except socket.gaierror as ex: - raise socket.gaierror('getaddrinfo failed for {0}:{1}, ' + raise socket.gaierror('getaddrinfo failed for {0}:{1}, ' 'exception was {2}. Is your advertised.host.name correct' ' and resolvable?'.format( self.host, self.port, ex |