Commit 4f8efa74 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Deployment: 

- Fixed Kafka namespace in initial checks + typos
- Added check to see cockroachDB started
parent ecb3e3da

deploy/crdb.sh

+7 −0
Original line number Diff line number Diff line
@@ -105,6 +105,13 @@ function crdb_deploy_single() { 
            sleep 1

        done

        kubectl wait --namespace ${CRDB_NAMESPACE} --for=condition=Ready --timeout=300s pod/cockroachdb-0



        # Wait for CockroachDB to notify "start_node_query"

        echo ">>> CockroachDB pods created. Waiting CockroachDB server to be started..."

        while ! kubectl --namespace ${CRDB_NAMESPACE} logs pod/cockroachdb-0 -c kafka 2>&1 | grep -q 'start_node_query'; do

            printf "%c" "."

            sleep 1

        done

    fi

    echo

deploy/kafka.sh

+5 −5
Original line number Diff line number Diff line
@@ -56,7 +56,7 @@ function kfk_deploy_single() { 


    echo "Kafka (single-mode)"

    echo ">>> Checking if Kafka is deployed..."

    if kubectl get --namespace ${CRDB_NAMESPACE} statefulset/kafka &> /dev/null; then

    if kubectl get --namespace ${KFK_NAMESPACE} statefulset/kafka &> /dev/null; then

        echo ">>> Kafka is present; skipping step."

    else

        echo ">>> Deploy Kafka"
@@ -64,7 +64,7 @@ function kfk_deploy_single() { 
        #sed -i "s/<KFK_NAMESPACE>/${KFK_NAMESPACE}/" "${TMP_MANIFESTS_FOLDER}/kfk_single_node.yaml"

        kubectl --namespace ${KFK_NAMESPACE} apply -f "${TMP_MANIFESTS_FOLDER}/kfk_single_node.yaml"



        echo ">>> Waiting Kakfa statefulset to be created..."

        echo ">>> Waiting Kafka statefulset to be created..."

        while ! kubectl get --namespace ${KFK_NAMESPACE} statefulset/kafka &> /dev/null; do

            printf "%c" "."

            sleep 1
@@ -78,7 +78,7 @@ function kfk_deploy_single() { 
        #kubectl wait --namespace  ${KFK_NAMESPACE} --for=condition=Available=True --timeout=300s statefulset/kafka

        #kubectl wait --namespace ${KGK_NAMESPACE} --for=jsonpath='{.status.readyReplicas}'=3 --timeout=300s \

        #    statefulset/kafka

        echo ">>> Kakfa statefulset created. Waiting Kakfa pods to be created..."

        echo ">>> Kafka statefulset created. Waiting Kafka pods to be created..."

        while ! kubectl get --namespace ${KFK_NAMESPACE} pod/kafka-0 &> /dev/null; do

            printf "%c" "."

            sleep 1
@@ -86,8 +86,8 @@ function kfk_deploy_single() { 
        kubectl wait --namespace ${KFK_NAMESPACE} --for=condition=Ready --timeout=300s pod/kafka-0



        # Wait for Kafka to notify "Kafka Server started"

        echo ">>> Kakfa pods created. Waiting Kakfa Server be started..."

        while ! kubectl --namespace $KFK_NAMESPACE logs pod/kafka-0 -c kafka 2>&1 | grep -q 'Kafka Server started'; do

        echo ">>> Kafka pods created. Waiting Kafka Server to be started..."

        while ! kubectl --namespace ${KFK_NAMESPACE} logs pod/kafka-0 -c kafka 2>&1 | grep -q 'Kafka Server started'; do

            printf "%c" "."

            sleep 1

        done