From d57db70a9896d76a8b75c7176d17520a8b81406b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mateusz=20S=C5=82abek?= Date: Wed, 27 Nov 2024 11:05:13 +0100 Subject: [PATCH] rename --- .../scala/pl/touk/nussknacker/engine/kafka/KafkaClient.scala | 4 ++-- 1 file changed, 2 insertions(+), 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 index e3229fefdd3..63889dacfd0 100644 --- 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 ) }