use python standard max value (#1303)

Author: OrangePieiep

kafka/client_async.py

@@ -947,7 +947,7 @@ def next_at(self):
         """Number of seconds until next task is ready."""
         self._drop_removed()
         if not self._tasks:
-            return 9999999999
+            return float('inf')
         else:
             return max(self._tasks[0][0] - time.time(), 0)
 

kafka/conn.py

@@ -607,7 +607,7 @@ def connection_delay(self):
         elif self.connecting():
             return 0
         else:
-            return 999999999
+            return float('inf')
 
     def connected(self):
         """Return True iff socket is connected."""

kafka/producer/kafka.py

@@ -437,7 +437,7 @@ def close(self, timeout=None):
             return
         if timeout is None:
             # threading.TIMEOUT_MAX is available in Python3.3+
-            timeout = getattr(threading, 'TIMEOUT_MAX', 999999999)
+            timeout = getattr(threading, 'TIMEOUT_MAX', float('inf'))
         if getattr(threading, 'TIMEOUT_MAX', False):
             assert 0 <= timeout <= getattr(threading, 'TIMEOUT_MAX')
         else:

kafka/producer/sender.py

@@ -103,7 +103,7 @@ def run_once(self):
             self._metadata.request_update()
 
         # remove any nodes we aren't ready to send to
-        not_ready_timeout = 999999999
+        not_ready_timeout = float('inf')
         for node in list(ready_nodes):
             if not self._client.ready(node):
                 log.debug('Node %s not ready; delaying produce of accumulated batch', node)