From d6e116ecce597ed5b8cde3ad904c7392bb5cec36 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Fri, 16 Apr 2021 12:19:30 +0200
Subject: [PATCH] Remove topics before resetting lag exporter
---
.../theodolite/benchmark/KubernetesBenchmarkDeployment.kt | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmarkDeployment.kt b/theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmarkDeployment.kt
index a9a7a4e38..0de00fb50 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmarkDeployment.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmarkDeployment.kt
@@ -46,10 +46,10 @@ class KubernetesBenchmarkDeployment(
* - Remove the [KubernetesResource]s.
*/
override fun teardown() {
- KafkaLagExporterRemover(client).remove(LABEL)
resources.forEach {
kubernetesManager.remove(it)
}
kafkaController.removeTopics(this.topics.map { topic -> topic.name() })
+ KafkaLagExporterRemover(client).remove(LABEL)
}
}
--
GitLab