From 0116b65af4d8e11f9db508a2f84ac87a96f3097e Mon Sep 17 00:00:00 2001 From: Martin Chacon Piza Date: Thu, 23 Aug 2018 14:39:36 +0200 Subject: [PATCH] Adding batch size for events configuration Change-Id: I42efe2330f014f3a59f9086070b020b67cd90162 --- monasca_persister/conf/kafka_events.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/monasca_persister/conf/kafka_events.py b/monasca_persister/conf/kafka_events.py index fd2eb40e..2bbaac06 100644 --- a/monasca_persister/conf/kafka_events.py +++ b/monasca_persister/conf/kafka_events.py @@ -39,6 +39,9 @@ kafka_events_opts = [ cfg.StrOpt('zookeeper_path', help='Path in zookeeper for kafka consumer group partitioning algorithm', default='/persister_partitions/$kafka_events.topic'), + cfg.IntOpt('batch_size', + help='Maximum number of events to buffer before writing to database', + default=1), ] # Replace Default OPT with reference to kafka group option