Skip to content
Snippets Groups Projects

Fixes the topic manager

1 file
+ 1
1
Compare changes
  • Side-by-side
  • Inline
@@ -40,7 +40,7 @@ class TopicManager(private val kafkaConfig: HashMap<String, Any>) {
@@ -40,7 +40,7 @@ class TopicManager(private val kafkaConfig: HashMap<String, Any>) {
val result = kafkaAdmin.deleteTopics(topics)
val result = kafkaAdmin.deleteTopics(topics)
result.all().get() // wait for the future object
result.all().get() // wait for the future object
logger.info {
logger.info {
"\"Topics deletion finished with result: ${
"Topics deletion finished with result: ${
result.values().map { it -> it.key + ": " + it.value.isDone }
result.values().map { it -> it.key + ": " + it.value.isDone }
.joinToString(separator = ",")
.joinToString(separator = ",")
} "
} "
Loading