jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

refactor(helm): format file.

Browse source 
Signed-off-by: rjshrjndrn <rjshrjndrn@gmail.com>
This commit is contained in:
rjshrjndrn 2022-06-21 09:39:12 +02:00
parent 6862652744
commit d7a4005adc
1 changed files with 26 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

50
scripts/helmcharts/openreplay/files/kafka.sh
View file

@ -1,42 +1,44 @@
#!/bin/bash
set -e
# Default to 4 days.
RETENTION_TIME=${RETENTION_TIME:-345600000}
topics=(
"raw"
"raw-ios"
"trigger"
"cache"
"analytics"
)
"raw"
"raw-ios"
"trigger"
"cache"
"analytics"
)
touch /tmp/config.txt
if [[ $KAFKA_SSL == "true" ]]; then
echo 'security.protocol=SSL' > /tmp/config.txt
echo 'security.protocol=SSL' > /tmp/config.txt
fi
function init() {
echo "Initializing kafka"
for topic in ${topics[*]}; do
echo "Creating topic: $topic"
# TODO: Have to check an idempotent way of creating topics.
kafka-topics.sh --create --bootstrap-server ${KAFKA_HOST}:${KAFKA_PORT} --replication-factor 2 --partitions 16 --topic ${topic} --command-config /tmp/config.txt || true
kafka-configs.sh --bootstrap-server ${KAFKA_HOST}:${KAFKA_PORT} --entity-type topics --alter --add-config retention.ms=${RETENTION_TIME} --entity-name=${topic} --command-config /tmp/config.txt || true
done
echo "Initializing kafka"
for topic in ${topics[*]}; do
echo "Creating topic: $topic"
# TODO: Have to check an idempotent way of creating topics.
kafka-topics.sh --create --bootstrap-server ${KAFKA_HOST}:${KAFKA_PORT} --replication-factor 2 --partitions 16 --topic ${topic} --command-config /tmp/config.txt || true
kafka-configs.sh --bootstrap-server ${KAFKA_HOST}:${KAFKA_PORT} --entity-type topics --alter --add-config retention.ms=${RETENTION_TIME} --entity-name=${topic} --command-config /tmp/config.txt || true
done
}
# /bin/bash kafka.sh migrate $migration_versions
case "$1" in
migrate)
init
;;
init)
init
;;
*)
echo "Unknown operation for kafka migration; exiting."
exit 1
;;
migrate)
init
;;
init)
init
;;
*)
echo "Unknown operation for kafka migration; exiting."
exit 1
;;
esac