openstack/monasca-persister
Code Issues Proposed changes

Add option for kafka client

Browse Source 
Add docker option for kafka client,enable confluent kafka or not.

Change-Id: Ib709bfaa8cc0f0fcebb191e6fc12e3cb888955a1
Task: 36351
Story: 2006436
This commit is contained in:
zhangjianweibj 2019-08-23 18:19:15 +08:00
parent 9665daafc0
commit e7956c9dfa
3 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
docker/Dockerfile
View File

@ -25,6 +25,7 @@ ENV \
KAFKA_ALARM_HISTORY_BATCH_SIZE=1000 \
KAFKA_ALARM_HISTORY_PROCESSORS=1 \
KAFKA_ALARM_HISTORY_WAIT_TIME=15 \
KAFKA_LEGACY_CLIENT_ENABLED=true \
KAFKA_METRICS_BATCH_SIZE=1000 \
KAFKA_METRICS_PROCESSORS=1 \
KAFKA_METRICS_WAIT_TIME=15 \

1
docker/README.rst
View File

@ -32,6 +32,7 @@ KAFKA_ALARM_HISTORY_BATCH_SIZE 1000 Kafka consumer takes messages
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_LEGACY_CLIENT_ENABLED true Enable legacy Kafka client
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

2
docker/monasca-persister.conf.j2
View File

@ -47,6 +47,7 @@ max_buffer_size = 32768
# Path in zookeeper for kafka consumer group partitioning algo
zookeeper_path = /persister_partitions/alarm-state-transitions
num_processors = {{ KAFKA_ALARM_HISTORY_PROCESSORS | default(1) }}
legacy_kafka_client_enabled= {{ KAFKA_LEGACY_CLIENT_ENABLED | default(true) }}
[kafka_events]
# Comma separated list of Kafka broker host:port.
@ -73,6 +74,7 @@ max_buffer_size = 32768
# Path in zookeeper for kafka consumer group partitioning algo
zookeeper_path = /persister_partitions/metrics
num_processors = {{ KAFKA_METRICS_PROCESSORS | default(1) }}
legacy_kafka_client_enabled= {{ KAFKA_LEGACY_CLIENT_ENABLED | default(true) }}
{% if DATABASE_BACKEND | lower == 'cassandra' %}
[cassandra]