From e6346b9dca879adab5d240d6d83f63b92927b711 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Mon, 6 Jan 2025 16:31:55 +0100
Subject: [PATCH] Fix tests

---
 .../com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java
index b9e1f2ca..31e25c8c 100644
--- a/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java
+++ b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java
@@ -705,7 +705,7 @@ private ImprovedAdminClient createAdminClient() {
     private List<KeyValue<String, Long>> readOutputTopic(final String outputTopic) {
         final List<ConsumerRecord<String, Long>> records = this.newContainerHelper().read()
                 .with(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, LongDeserializer.class)
-                .from(outputTopic, Duration.ofSeconds(1L));
+                .from(outputTopic, TIMEOUT);
         return records.stream()
                 .map(record -> new KeyValue<>(record.key(), record.value()))
                 .collect(Collectors.toList());