diff options
| -rw-r--r-- | kafka/client.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/client.py b/kafka/client.py index 22918ac..9abc94b 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -76,7 +76,7 @@ class SimpleClient(object): return conn timeout = time.time() + self.timeout - while time.time() < timeout and conn.connecting(): + while time.time() < timeout: if conn.connect() is ConnectionStates.CONNECTED: break else: |