From 95d6a38eb1ce1011b3ca6adddfe4cf50006b73b0 Mon Sep 17 00:00:00 2001
From: "stu126940@mail.uni-kiel.de" <stu126940@mail.uni-kiel.de>
Date: Wed, 14 Apr 2021 09:09:44 +0200
Subject: [PATCH] wait of the future from the kafka client
---
.../src/main/kotlin/theodolite/k8s/TopicManager.kt | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/k8s/TopicManager.kt b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/TopicManager.kt
index 390974cd2..dd694e88f 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/k8s/TopicManager.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/TopicManager.kt
@@ -20,9 +20,9 @@ class TopicManager(private val kafkaConfig: HashMap<String, Any>) {
*/
fun createTopics(newTopics: Collection<NewTopic>) {
var kafkaAdmin: AdminClient = AdminClient.create(this.kafkaConfig)
- kafkaAdmin.createTopics(newTopics)
+ val result = kafkaAdmin.createTopics(newTopics)
+ logger.info { "Topics created finished with result: ${result.all().get()}" }
kafkaAdmin.close()
- logger.info { "Topics created" }
}
@@ -32,10 +32,10 @@ class TopicManager(private val kafkaConfig: HashMap<String, Any>) {
*/
fun removeTopics(topics: List<String>) {
var kafkaAdmin: AdminClient = AdminClient.create(this.kafkaConfig)
- val result = kafkaAdmin.deleteTopics(topics)
try {
- result.all().get()
+ val result = kafkaAdmin.deleteTopics(topics)
+ logger.info { "Topics deletion finished with result: ${result.all().get()}" }
} catch (e: Exception) {
logger.error { "Error while removing topics: $e" }
logger.debug { "Existing topics are: ${kafkaAdmin.listTopics()}." }
--
GitLab