diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py
index 8b5dbec..c1cb311 100644
--- a/test/test_consumer_integration.py
+++ b/test/test_consumer_integration.py
@@ -475,8 +475,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
         self.send_messages(1, range(100, 200))
 
         # Start a consumer
-        consumer = self.kafka_consumer(auto_offset_reset='earliest',
-                                       consumer_timeout_ms=5000)
+        consumer = self.kafka_consumer(auto_offset_reset='earliest')
         n = 0
         messages = {0: set(), 1: set()}
         for m in consumer: