Skip to content
Snippets Groups Projects

Fix TopicManager

3 files
+ 62
21
Compare changes
  • Side-by-side
  • Inline
Files
3
@@ -47,9 +47,9 @@ class KubernetesBenchmarkDeployment(
@@ -47,9 +47,9 @@ class KubernetesBenchmarkDeployment(
*/
*/
override fun teardown() {
override fun teardown() {
KafkaLagExporterRemover(client).remove(LABEL)
KafkaLagExporterRemover(client).remove(LABEL)
kafkaController.removeTopics(this.topics.map { topic -> topic.name() })
resources.forEach {
resources.forEach {
kubernetesManager.remove(it)
kubernetesManager.remove(it)
}
}
 
kafkaController.removeTopics(this.topics.map { topic -> topic.name() })
}
}
}
}
Loading