openstack/deb-python-kafka
Code Issues Proposed changes

Drop request_timeout_ms override in consumer group test

Browse Source
This commit is contained in:
Dana Powers
2016-01-04 00:55:55 -08:00
parent 1a0b86625f
commit 16e35c9d16
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_group.py
View File

@@ -94,8 +94,7 @@ def test_group(kafka_broker, topic):
stop[i] = threading.Event() stop[i] = threading.Event()
consumers[i] = KafkaConsumer(topic, consumers[i] = KafkaConsumer(topic,
bootstrap_servers=connect_str, bootstrap_servers=connect_str,
heartbeat_interval_ms=500, heartbeat_interval_ms=500)
request_timeout_ms=1000)
while not stop[i].is_set(): while not stop[i].is_set():
for tp, records in six.itervalues(consumers[i].poll()): for tp, records in six.itervalues(consumers[i].poll()):
messages[i][tp].extend(records) messages[i][tp].extend(records)