diff options
| author | Bryan Newbold <bnewbold@archive.org> | 2021-02-15 21:51:06 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@archive.org> | 2021-02-15 21:51:06 -0800 |
| commit | 55bd186a21f5e3703e8f3ba3b0a14f1387ed0ccc (patch) | |
| tree | dd523a15ac6147c551f9fff7bedfc0b47a6467a6 /fatcat_scholar/kafka.py | |
| parent | bc66be001605454b48a36dd38bffee405bf469ab (diff) | |
| download | fatcat-scholar-55bd186a21f5e3703e8f3ba3b0a14f1387ed0ccc.tar.gz fatcat-scholar-55bd186a21f5e3703e8f3ba3b0a14f1387ed0ccc.zip | |
increase indexing timeout to 50sec (60sec for kafka)
Diffstat (limited to 'fatcat_scholar/kafka.py')
| -rw-r--r-- | fatcat_scholar/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/fatcat_scholar/kafka.py b/fatcat_scholar/kafka.py index 5faff9a..e71bc3d 100644 --- a/fatcat_scholar/kafka.py +++ b/fatcat_scholar/kafka.py @@ -60,7 +60,7 @@ class KafkaWorker(object): self.counts: Counter = Counter() self.kafka_brokers = kafka_brokers self.batch_size = kwargs.get("batch_size", 1) - self.batch_timeout_sec = kwargs.get("batch_timeout_sec", 30) + self.batch_timeout_sec = kwargs.get("batch_timeout_sec", 60) self.poll_interval_sec = kwargs.get("poll_interval_sec", 5.0) self.consumer = self.create_kafka_consumer( kafka_brokers, consume_topics, consumer_group |