Skip to content

Commit

Permalink
Merge pull request #49 from lalithkota/develop
Browse files Browse the repository at this point in the history
Init Helm Chart: Fixed existing connectors problem
  • Loading branch information
lalithkota authored Nov 5, 2024
2 parents 4e0450e + 09d8edb commit 8f75915
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions charts/reporting-init/values.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -223,14 +223,14 @@ startUpCommand: |-
config_var=$1
config_file_path=$2
config_json=$(cat $config_file_path 2>/dev/null || echo)
envsubst <<< "$config_json" | jq -cj "$config_var // empty"
envsubst <<< "$config_json" | jq -cj ".$config_var // empty"
}
echo "====> DEBEZIUM CONNECTORS"
if [ "$INIT_DEBEZIUM_CONNECTORS" = "true" ] && [ -d debezium-connectors ]; then
echo "==> Starting Debezium Connector Initialization"
TEMP_DEBEZIUM_CONNECTOR_FILE="/tmp/temp_debez_conn.json"
debezium_existing_connectors_list=$(curl -s $DEBEZIUM_URL/connectors | jq -cj '.[]')
debezium_existing_connectors_list=$(curl -s $DEBEZIUM_URL/connectors | jq -cr '.[]')
debezium_new_connectors_list=()
for debezium_conn in debezium-connectors/*.json ; do
envsubst < $debezium_conn > $TEMP_DEBEZIUM_CONNECTOR_FILE
Expand Down Expand Up @@ -274,7 +274,7 @@ startUpCommand: |-
if [ "$INIT_OS_KAFKA_CONNECTORS" = "true" ] && [ -d opensearch-connectors ]; then
echo "==> Starting Opensearch Connector Initialization"
TEMP_OS_KAFKA_CONNECTOR_FILE="/tmp/temp_os_kafka_conn.json"
os_existing_connectors_list=$(curl -s $OS_KAFKA_CONNECTOR_URL/connectors | jq -cj '.[]')
os_existing_connectors_list=$(curl -s $OS_KAFKA_CONNECTOR_URL/connectors | jq -cr '.[]')
os_new_connectors_list=()
for os_conn in opensearch-connectors/*.json ; do
envsubst < $os_conn > $TEMP_OS_KAFKA_CONNECTOR_FILE
Expand Down

0 comments on commit 8f75915

Please sign in to comment.