rename

TouK · Nov 27, 2024 · d57db70 · d57db70
1 parent 21bad8d
commit d57db70
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/utils/kafka-test-utils/src/main/scala/pl/touk/nussknacker/engine/kafka/KafkaClient.scala b/utils/kafka-test-utils/src/main/scala/pl/touk/nussknacker/engine/kafka/KafkaClient.scala
@@ -32,14 +32,14 @@ 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
-    val maxTime = 10.seconds
+    val timeout = 10.seconds
     Await.result(
       retry.Pause(10, 1.second)(Timer.default)(
         Future {
           topic(name)
         }
       ),
-      maxTime
+      timeout
     )
   }