diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/k8s/TopicManager.kt b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/TopicManager.kt index 390974cd247645197ebe6044bf785710164155aa..dd694e88f2e247a2cdbec251d9eb1766436f9196 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()}." }