openstack/deb-python-kafka
Code Issues Proposed changes

Dont use consumer_timeout_ms in simple kafka_consumer test

Browse Source
This commit is contained in:
Dana Powers
2016-01-04 00:19:38 -08:00
parent 16c834119b
commit 1a0b86625f
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
test/test_consumer_integration.py
View File

@@ -475,8 +475,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
self.send_messages(1, range(100, 200)) self.send_messages(1, range(100, 200))
# Start a consumer # Start a consumer
consumer = self.kafka_consumer(auto_offset_reset='earliest', consumer = self.kafka_consumer(auto_offset_reset='earliest')
consumer_timeout_ms=5000)
n = 0 n = 0
messages = {0: set(), 1: set()} messages = {0: set(), 1: set()}
for m in consumer: for m in consumer: