Document api_version_auto_timeout_ms default; override in group tests

Author: dpkp

kafka/client_async.py

@@ -150,6 +150,7 @@ class KafkaClient(object):
         api_version_auto_timeout_ms (int): number of milliseconds to throw a
             timeout exception from the constructor when checking the broker
             api version. Only applies if api_version set to None.
+            Default: 2000
         selector (selectors.BaseSelector): Provide a specific selector
             implementation to use for I/O multiplexing.
             Default: selectors.DefaultSelector

kafka/consumer/group.py

@@ -224,6 +224,7 @@ class KafkaConsumer(six.Iterator):
         api_version_auto_timeout_ms (int): number of milliseconds to throw a
             timeout exception from the constructor when checking the broker
             api version. Only applies if api_version set to None.
+            Default: 2000
         connections_max_idle_ms: Close idle connections after the number of
             milliseconds specified by this config. The broker closes idle
             connections after connections.max.idle.ms, so this avoids hitting

kafka/producer/kafka.py

@@ -272,6 +272,7 @@ class KafkaProducer(object):
         api_version_auto_timeout_ms (int): number of milliseconds to throw a
             timeout exception from the constructor when checking the broker
             api version. Only applies if api_version set to None.
+            Default: 2000
         metric_reporters (list): A list of classes to use as metrics reporters.
             Implementing the AbstractMetricsReporter interface allows plugging
             in classes that will be notified of new metric creation. Default: []

test/test_consumer_group.py

@@ -57,6 +57,7 @@ def consumer_thread(i):
                                      bootstrap_servers=connect_str,
                                      group_id=group_id,
                                      client_id="consumer_thread-%s" % i,
+                                     api_version_auto_timeout_ms=30000,
                                      heartbeat_interval_ms=500)
         while not stop[i].is_set():
             for tp, records in six.itervalues(consumers[i].poll(timeout_ms=200)):
@@ -156,6 +157,7 @@ def test_heartbeat_thread(kafka_broker, topic):
     consumer = KafkaConsumer(topic,
                              bootstrap_servers=get_connect_str(kafka_broker),
                              group_id=group_id,
+                             api_version_auto_timeout_ms=30000,
                              heartbeat_interval_ms=500)
 
     # poll until we have joined group / have assignment