From f2bc1e87088d1e2c4b99c228251c0de95fc13c69 Mon Sep 17 00:00:00 2001 From: "jianhao.cjh" Date: Tue, 25 Aug 2020 10:52:17 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=20max=5Ffetch=5Flog=5Fgroup?= =?UTF-8?q?=5Fsize=20=E5=8F=82=E6=95=B0=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- aliyun/log/consumer/worker.py | 1 + 1 file changed, 1 insertion(+) diff --git a/aliyun/log/consumer/worker.py b/aliyun/log/consumer/worker.py index 7a73d692..309d4eb3 100755 --- a/aliyun/log/consumer/worker.py +++ b/aliyun/log/consumer/worker.py @@ -192,6 +192,7 @@ def _get_shard_consumer(self, shard_id): consumer = ShardConsumerWorker(self.consumer_client, shard_id, self.option.consumer_name, processer, self.option.cursor_position, self.option.cursor_start_time, + max_fetch_log_group_size=self.option.max_fetch_log_group_size, executor=self._executor, cursor_end_time=self.option.cursor_end_time) self.shard_consumers[shard_id] = consumer