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