Skip to content
Snippets Groups Projects
Commit ef35f577 authored by Björn Vonheiden's avatar Björn Vonheiden
Browse files

enchance topic deletion in run uc py

parent 1b274cb0
No related branches found
No related tags found
No related merge requests found
...@@ -325,11 +325,13 @@ def delete_topics(topics): ...@@ -325,11 +325,13 @@ def delete_topics(topics):
""" """
print('Delete topics from Kafka') print('Delete topics from Kafka')
topics_delete = 'theodolite-.*|' + '|'.join([ti[0] for ti in topics])
num_topics_command = [ num_topics_command = [
'/bin/sh', '/bin/sh',
'-c', '-c',
f'kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list \ f'kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --list \
| sed -n -E "/^(theodolite-.*|input|output|configuration)\ | sed -n -E "/^({topics_delete})\
( - marked for deletion)?$/p" | wc -l' ( - marked for deletion)?$/p" | wc -l'
] ]
...@@ -337,7 +339,7 @@ def delete_topics(topics): ...@@ -337,7 +339,7 @@ def delete_topics(topics):
'/bin/sh', '/bin/sh',
'-c', '-c',
f'kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete \ f'kafka-topics --zookeeper my-confluent-cp-zookeeper:2181 --delete \
--topic "input|output|configuration|theodolite-.*"' --topic "{topics_delete}"'
] ]
# Wait that topics get deleted # Wait that topics get deleted
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment