diff --git a/docker/README.rst b/docker/README.rst index d7085dc6..286cdcd7 100644 --- a/docker/README.rst +++ b/docker/README.rst @@ -31,6 +31,7 @@ KAFKA_URI kafka:9092 The host and port for kafka KAFKA_ALARM_HISTORY_BATCH_SIZE 1000 Kafka consumer takes messages in a batch KAFKA_ALARM_HISTORY_PROCESSORS 1 Number of processes for alarm history topic KAFKA_ALARM_HISTORY_WAIT_TIME 15 Seconds to wait if the batch size is not reached +KAFKA_EVENTS_ENABLE false Enable events persister KAFKA_METRICS_BATCH_SIZE 1000 Kafka consumer takes messages in a batch KAFKA_METRICS_PROCESSORS 1 Number of processes for metrics topic KAFKA_METRICS_WAIT_TIME 15 Seconds to wait if the batch size is not reached diff --git a/docker/monasca-persister.conf.j2 b/docker/monasca-persister.conf.j2 index dfca35ab..de3d5168 100644 --- a/docker/monasca-persister.conf.j2 +++ b/docker/monasca-persister.conf.j2 @@ -48,6 +48,14 @@ max_buffer_size = 32768 zookeeper_path = /persister_partitions/alarm-state-transitions num_processors = {{ KAFKA_ALARM_HISTORY_PROCESSORS | default(1) }} +[kafka_events] +# Comma separated list of Kafka broker host:port. +uri = {{ KAFKA_URI }} +enabled = {{ KAFKA_EVENTS_ENABLE | default(false) }} +group_id = 1_events +topic = monevents +batch_size = 1 + [kafka_metrics] # Comma separated list of Kafka broker host:port uri = {{ KAFKA_URI }}