Skip to content
Snippets Groups Projects
Commit 1d5d4c63 authored by Sören Henning's avatar Sören Henning
Browse files

Try to remove topics periodically

parent af6e5b37
No related branches found
No related tags found
No related merge requests found
...@@ -49,4 +49,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c ...@@ -49,4 +49,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c
do do
echo "Wait for topic deletion" echo "Wait for topic deletion"
sleep 5s 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 done
...@@ -48,4 +48,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c ...@@ -48,4 +48,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c
do do
echo "Wait for topic deletion" echo "Wait for topic deletion"
sleep 5s 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 done
...@@ -48,4 +48,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c ...@@ -48,4 +48,6 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c
do do
echo "Wait for topic deletion" echo "Wait for topic deletion"
sleep 5s 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 done
...@@ -48,6 +48,8 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c ...@@ -48,6 +48,8 @@ while test $(kubectl exec kafka-client -- bash -c "kafka-topics --zookeeper my-c
do do
echo "Wait for topic deletion" echo "Wait for topic deletion"
sleep 5s 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 done
#TODO maybe delete schemas #TODO maybe delete schemas
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment