From b2bc1f0ed7b339b111e02afec1d8b7aa1d8495da Mon Sep 17 00:00:00 2001
From: tyronecai <tyronecai@163.com>
Date: Thu, 23 Jun 2016 23:01:38 +0800
Subject: assert will be disabled by "python -O" (#736)

---
 kafka/conn.py | 8 ++++----
 1 file 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
-- 
cgit v1.2.1