Drop request_timeout_ms override in consumer group test

Dana Powers · Dana Powers · commit 16e35c9d160d · 2016-01-04T00:55:55.000-08:00
diff --git a/test/test_consumer_group.py b/test/test_consumer_group.py
@@ -94,8 +94,7 @@ def consumer_thread(i):
         stop[i] = threading.Event()
         consumers[i] = KafkaConsumer(topic,
                                      bootstrap_servers=connect_str,
-                                     heartbeat_interval_ms=500,
-                                     request_timeout_ms=1000)
+                                     heartbeat_interval_ms=500)
         while not stop[i].is_set():
             for tp, records in six.itervalues(consumers[i].poll()):
                 messages[i][tp].extend(records)
