openstack/deb-python-kafka
Code Issues Proposed changes

Fast heartbeats during consumer group tests

Browse Source
This commit is contained in:
Dana Powers
2016-01-03 22:43:39 -08:00
parent 03d37dff5c
commit 09358f9c82
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
test/test_consumer_group.py
View File

@@ -94,6 +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,
request_timeout_ms=1000) 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()):