41 lines
1.4 KiB
Bash
41 lines
1.4 KiB
Bash
#!/bin/bash
|
|
|
|
tenant=${tenant}
|
|
#env=${env}
|
|
env="qa"
|
|
while [ $# -gt 0 ]; do
|
|
if [[ $1 == *"--"* ]]; then
|
|
param="${1/--/}"
|
|
declare $param="$2"
|
|
fi
|
|
shift
|
|
done
|
|
|
|
if [ -z "$tenant" ]; then
|
|
echo "--tenant is not set"
|
|
exit 2
|
|
fi
|
|
|
|
if [ -z "$env" ]; then
|
|
echo "--env is not set"
|
|
exit 2
|
|
fi
|
|
|
|
containerId="$(docker ps | grep 'kafka_kafka-dev-1_1' | sed 's/\|/ /'|awk '{print $1}')"
|
|
declare -a queues=("sms_message_order_" "sms_message_order_dlq_" "sms_message_order_reply_" "vpn_order_" "vpn_order_dlq_" "vpn_order_reply_" "billing_seller_order_" "billing_seller_order_reply_" "billing_account_order_" "billing_account_order_dlq_" "billing_account_order_reply_" "create_customer_hierarchy_" "create_customer_hierarchy_reply_" "billing_order_create_" "create_plan_" "create_plan_reply_" "create_plan_dlq_" "supplementary_plan_save_" "supplementary_plan_save_reply_" "supplementary_plan_save_dlq_" "ordering_submit_" "ordering_success_" "ordering_dlq_")
|
|
|
|
for queue in "${queues[@]}"; do
|
|
if [ "$env" == "prod" ]; then
|
|
queue=$queue
|
|
elif [ "$env" == "qa" ]; then
|
|
queue="qa_"$queue
|
|
elif [ "$env" == "staging" ]; then
|
|
queue="staging_"$queue
|
|
else
|
|
queue="development_"$queue
|
|
fi
|
|
queue=$queue$tenant
|
|
echo "preparing to create queue: $queue"
|
|
docker exec $containerId /opt/bitnami/kafka/bin/kafka-topics.sh --create --topic $queue --replication-factor 1 --partitions 1 --bootstrap-server 85.184.249.102:9092
|
|
done
|