aboutsummaryrefslogtreecommitdiffstats
path: root/python/kafka_grobid.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/kafka_grobid.py')
-rwxr-xr-xpython/kafka_grobid.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/python/kafka_grobid.py b/python/kafka_grobid.py
index fc4e461..df222d8 100755
--- a/python/kafka_grobid.py
+++ b/python/kafka_grobid.py
@@ -252,8 +252,8 @@ class KafkaGrobidWorker:
compression=pykafka.common.CompressionType.GZIP,
retry_backoff_ms=250,
max_queued_messages=20,
- min_queued_messages=1,
- linger_ms=0,
+ min_queued_messages=3,
+ linger_ms=2000,
max_request_size=self.produce_max_request_size) as producer:
print("Producing to: {}".format(self.produce_topic))
consumer = consume_topic.get_balanced_consumer(