Merge "Adding batch size for events configuration"

This commit is contained in:
Zuul 2018-08-28 15:06:14 +00:00 committed by Gerrit Code Review
commit 8db160582a
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