diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index b2d28056c..3b530d58d 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -602,12 +602,8 @@ def __getattr__(self, name):
             log.info('%s: Kafka producer closed', str(self))
             return
         if timeout is None:
-            # threading.TIMEOUT_MAX is available in Python3.3+
-            timeout = getattr(threading, 'TIMEOUT_MAX', float('inf'))
-        if getattr(threading, 'TIMEOUT_MAX', False):
-            assert 0 <= timeout <= getattr(threading, 'TIMEOUT_MAX')
-        else:
-            assert timeout >= 0
+            timeout = threading.TIMEOUT_MAX
+        assert 0 <= timeout <= threading.TIMEOUT_MAX
 
         log.info("%s: Closing the Kafka producer with %s secs timeout.", str(self), timeout)
         self.flush(timeout)