dpkp
diff --git a/‎kafka/client_async.py
Copy file name to clipboardExpand all lines: kafka/client_async.py
+2-2Lines changed: 2 additions & 2 deletions b/‎kafka/client_async.py
Copy file name to clipboardExpand all lines: kafka/client_async.py
+2-2Lines changed: 2 additions & 2 deletions
@@ -591,9 +591,9 @@ def poll(self, timeout_ms=None, future=None):
                     # 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())