diff options
| -rw-r--r-- | test/test_consumer_integration.py | 3 |
1 files changed, 1 insertions, 2 deletions
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: |