refactor: increase the timeout for publish/consume kafka tests

Author: osoykan

starters/spring/tests/spring-test-fixtures/src/testFixtures/kotlin/com/trendyol/stove/testing/e2e/kafka/StringSerdeKafkaSystemTests.kt

@@ -7,6 +7,7 @@ import io.kotest.core.spec.style.ShouldSpec
 import io.kotest.matchers.shouldBe
 import org.apache.kafka.clients.admin.NewTopic
 import kotlin.random.Random
+import kotlin.time.Duration.Companion.seconds
 
 /**
  * Shared Kafka string serde tests that work across all Spring Boot versions.
@@ -78,14 +79,13 @@ abstract class StringSerdeKafkaSystemTests(
       validate {
         kafka {
           val userId = Random.nextInt().toString()
-          val message =
-            "this message is coming from ${testCase.descriptor.id.value} and testName is ${testCase.name.name}"
+          val message = "this message is coming from ${testCase.descriptor.id.value} and testName is ${testCase.name.name}"
           val headers = mapOf("x-user-id" to userId)
           publish("topic", message, serde = StoveSerde.jackson.anyJsonStringSerde().some(), headers = headers)
-          shouldBePublished<String> {
+          shouldBePublished<String>(atLeastIn = 20.seconds) {
             actual == message && this.metadata.headers["x-user-id"] == userId && this.metadata.topic == "topic"
           }
-          shouldBeConsumed<String> {
+          shouldBeConsumed<String>(atLeastIn = 20.seconds) {
             actual == message && this.metadata.headers["x-user-id"] == userId && this.metadata.topic == "topic"
           }
         }