try to fix kafka test not waiting for created topic

utils/kafka-test-utils/src/main/scala/pl/touk/nussknacker/engine/kafka/KafkaClient.scala

@@ -7,13 +7,12 @@ import org.apache.kafka.clients.admin.{NewTopic, TopicDescription}
 import org.apache.kafka.clients.consumer.KafkaConsumer
 import org.apache.kafka.clients.producer.{Callback, KafkaProducer, ProducerRecord, RecordMetadata}
 import org.apache.kafka.common.header.Headers
-import retry.When
 
 import java.time.Duration
 import java.util
 import java.util.{Collections, UUID}
 import scala.concurrent.ExecutionContext.Implicits.global
-import scala.concurrent.{Future, Promise}
+import scala.concurrent.{Await, Future, Promise}
 import scala.jdk.CollectionConverters._
 import scala.util.{Failure, Success, Try}
 import scala.concurrent.duration._
@@ -33,12 +32,15 @@ class KafkaClient(kafkaAddress: String, id: String) extends LazyLogging {
   def createTopic(name: String, partitions: Int = 5): Unit = {
     adminClient.createTopics(Collections.singletonList(new NewTopic(name, partitions, 1: Short))).all().get()
     // When kraft enabled, topics doesn't appear instantly after createTopic
-    retry.Pause(10, 1.second)(Timer.default)(
-      Future {
-        topic(name)
-      }
+    val maxTime = 10.seconds
+    Await.result(
+      retry.Pause(10, 1.second)(Timer.default)(
+        Future {
+          topic(name)
+        }
+      ),
+      maxTime
     )
-
   }
 
   def deleteTopic(name: String): Unit =