From 1d5d4c636a44c3d0f5a26faeca1a4965e3ce0ba7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <post@soeren-henning.de>
Date: Fri, 27 Mar 2020 17:42:03 +0100
Subject: [PATCH] Try to remove topics periodically
---
execution/run_uc1-new.sh | 2 ++
execution/run_uc2-new.sh | 2 ++
execution/run_uc3-new.sh | 2 ++
execution/run_uc4-new.sh | 2 ++
4 files changed, 8 insertions(+)
diff --git a/execution/run_uc1-new.sh b/execution/run_uc1-new.sh
index cb3aef78b..446d54f48 100755
--- a/execution/run_uc1-new.sh
+++ b/execution/run_uc1-new.sh
@@ -49,4 +49,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c
do
echo "Wait for topic deletion"
sleep 5s
+ # Sometimes a second deletion seems to be required
+ kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'"
done
diff --git a/execution/run_uc2-new.sh b/execution/run_uc2-new.sh
index 1efd95780..1e0c1d819 100755
--- a/execution/run_uc2-new.sh
+++ b/execution/run_uc2-new.sh
@@ -48,4 +48,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c
do
echo "Wait for topic deletion"
sleep 5s
+ # Sometimes a second deletion seems to be required
+ kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'"
done
diff --git a/execution/run_uc3-new.sh b/execution/run_uc3-new.sh
index 17553309e..2fa5efae3 100755
--- a/execution/run_uc3-new.sh
+++ b/execution/run_uc3-new.sh
@@ -48,4 +48,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c
do
echo "Wait for topic deletion"
sleep 5s
+ # Sometimes a second deletion seems to be required
+ kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'"
done
diff --git a/execution/run_uc4-new.sh b/execution/run_uc4-new.sh
index c0dcc347c..095e052b5 100755
--- a/execution/run_uc4-new.sh
+++ b/execution/run_uc4-new.sh
@@ -48,6 +48,8 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c
do
echo "Wait for topic deletion"
sleep 5s
+ # Sometimes a second deletion seems to be required
+ kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete --topic 'input,output,configuration,titan-.*'"
done
#TODO maybe delete schemas
--
GitLab