diff --git a/execution/run_uc1-new.sh b/execution/run_uc1-new.sh index b53b4519741580bd4be86c181d715088ed8744ed..cb3aef78bd07db24b220a728a9b296e510502567 100755 --- a/execution/run_uc1-new.sh +++ b/execution/run_uc1-new.sh @@ -37,7 +37,16 @@ kubectl delete -f uc1-application/aggregation-deployment.yaml # Delete topics instead of Kafka -kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" # kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic '.*' -sleep 30s # TODO check -kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" +#sleep 30s # TODO check +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' | wc -l +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" + +kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" +while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' | wc -l) -gt 0 +do + echo "Wait for topic deletion" + sleep 5s +done diff --git a/execution/run_uc2-new.sh b/execution/run_uc2-new.sh index 4c6dc1edbdadd111fd48c4fa9d66b993f443581d..1efd9578044ac099f6ae226e8240e61e952edb3b 100755 --- a/execution/run_uc2-new.sh +++ b/execution/run_uc2-new.sh @@ -36,7 +36,16 @@ kubectl delete -f uc2-application/aggregation-deployment.yaml # Delete topics instead of Kafka -kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" # kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic '.*' -sleep 10s # TODO check -kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" +#sleep 30s # TODO check +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' | wc -l +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" + +kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" +while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' | wc -l) -gt 0 +do + echo "Wait for topic deletion" + sleep 5s +done diff --git a/execution/run_uc3-new.sh b/execution/run_uc3-new.sh index e7077697e876c475c0be68f9bad76238d6a1583c..17553309e0527a21397883515046723cd919fb28 100755 --- a/execution/run_uc3-new.sh +++ b/execution/run_uc3-new.sh @@ -36,7 +36,16 @@ kubectl delete -f uc3-application/aggregation-deployment.yaml # Delete topics instead of Kafka -kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" # kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic '.*' -sleep 10s # TODO check -kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" +#sleep 30s # TODO check +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' | wc -l +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" + +kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" +while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' | wc -l) -gt 0 +do + echo "Wait for topic deletion" + sleep 5s +done diff --git a/execution/run_uc4-new.sh b/execution/run_uc4-new.sh index 0e8e7e989fb7014ff62ff2ffdc18fd3f831cd9f2..c0dcc347c5cf06b7ee8fe2818019559969006c1b 100755 --- a/execution/run_uc4-new.sh +++ b/execution/run_uc4-new.sh @@ -36,10 +36,19 @@ kubectl delete -f uc4-application/aggregation-deployment.yaml # Delete topics instead of Kafka -kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" # kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic '.*' -sleep 10s # TODO check -kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" +#sleep 30s # TODO check +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' | wc -l +#kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" + +kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'" +while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list" | sed -n '/^titan-.*/p;/^input$/p;/^output$/p;/^configuration$/p' | wc -l) -gt 0 +do + echo "Wait for topic deletion" + sleep 5s +done #TODO maybe delete schemas #https://docs.confluent.io/current/schema-registry/schema-deletion-guidelines.html