diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-04 00:19:38 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-04 00:19:38 -0800 |
| commit | 1a0b86625f265aa1e0edcf7f1909be3a572a2994 (patch) | |
| tree | 7717dbc5929eb64d774d05bce877028d083a81d6 | |
| parent | 16c834119b6113450a59a05ce627669ba5752f37 (diff) | |
| download | kafka-python-1a0b86625f265aa1e0edcf7f1909be3a572a2994.tar.gz | |
Dont use consumer_timeout_ms in simple kafka_consumer test
| -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: |