From cc27836cdcab65d6a6cad8774d2829f76026ed5d Mon Sep 17 00:00:00 2001 From: zhangjianweibj Date: Mon, 1 Jul 2019 10:05:15 +0800 Subject: [PATCH] Support Kafka_events option in docker evn Support kafka_events option in dockerfile. Change-Id: Ie97cdef3f8314efea4292ea80c05a7dfea2bf609 Story: 2006138 Task: 35634 --- docker/README.rst | 1 + docker/monasca-persister.conf.j2 | 8 ++++++++ 2 files changed, 9 insertions(+) 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 }}