Delay converting to seconds

Delaying the conversion to seconds makes the code intent more clear.

1 files changed, 2 insertions, 2 deletions

diff --git a/kafka/client_async.py b/kafka/client_async.py
index 42ec42b..96c0647 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -591,9 +591,9 @@ class KafkaClient(object):
                     # if there are no requests in flight, do not block longer than the retry backoff
                     if self.in_flight_request_count() == 0:
                         timeout = min(timeout, self.config['retry_backoff_ms'])
-                    timeout = max(0, timeout / 1000)  # avoid negative timeouts
+                    timeout = max(0, timeout)  # avoid negative timeouts
 
-                self._poll(timeout)
+                self._poll(timeout / 1000)
 
                 responses.extend(self._fire_pending_completed_requests())