From 009290ddd5d4616d70bff93f841e773af8b22750 Mon Sep 17 00:00:00 2001
From: lukeWx <4403510+lukekingbru@users.noreply.github.com>
Date: Thu, 7 Dec 2017 13:59:58 -0800
Subject: use python standard max value (#1303)

---
 kafka/client_async.py    | 2 +-
 kafka/conn.py            | 2 +-
 kafka/producer/kafka.py  | 2 +-
 kafka/producer/sender.py | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/kafka/client_async.py b/kafka/client_async.py
index e36d78e..1350503 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -947,7 +947,7 @@ class DelayedTaskQueue(object):
         """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)
 
diff --git a/kafka/conn.py b/kafka/conn.py
index 2d6e5ce..e20210a 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -607,7 +607,7 @@ class BrokerConnection(object):
         elif self.connecting():
             return 0
         else:
-            return 999999999
+            return float('inf')
 
     def connected(self):
         """Return True iff socket is connected."""
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index 646e773..5d32b13 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -437,7 +437,7 @@ class KafkaProducer(object):
             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:
diff --git a/kafka/producer/sender.py b/kafka/producer/sender.py
index ffc67f8..48ad06e 100644
--- a/kafka/producer/sender.py
+++ b/kafka/producer/sender.py
@@ -103,7 +103,7 @@ class Sender(threading.Thread):
             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)
-- 
cgit v1.2.1