Adding batch size for events configuration

Change-Id: I42efe2330f014f3a59f9086070b020b67cd90162
This commit is contained in:
Martin Chacon Piza 2018-08-23 14:39:36 +02:00
parent 559483118b
commit 0116b65af4
1 changed files with 3 additions and 0 deletions

View File

@ -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