Fix tests

bakdata · Jan 6, 2025 · e6346b9 · e6346b9
1 parent 81dfe81
commit e6346b9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java b/...-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());