Commit e87b2797 authored by Lionel Walter's avatar Lionel Walter
Browse files

Wait longer for Kafka responses

parent 17eea4c5
......@@ -25,7 +25,7 @@ def get_report(topic_name):
try: # read job-reporting messages from kafka
job_messages = consumer.poll(1000, 1000)
job_messages = consumer.poll(timeout_ms=10000, max_records=1000)
processed = succeeded = 0
if job_messages:
for partition in job_messages:
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment