sped up integration test

Aiven-Open · Jan 2, 2025 · df11418 · df11418
1 parent e744e32
commit df11418
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java b/...connector/src/integration-test/java/io/aiven/kafka/connect/s3/source/IntegrationBase.java
@@ -203,7 +203,7 @@ static <K, V> List<V> consumeMessages(final String topic, final int expectedMess
             consumer.subscribe(Collections.singletonList(topic));
 
             final List<V> recordValues = new ArrayList<>();
-            await().atMost(Duration.ofMinutes(5)).pollInterval(Duration.ofSeconds(5)).untilAsserted(() -> {
+            await().atMost(Duration.ofMinutes(1)).pollInterval(Duration.ofSeconds(5)).untilAsserted(() -> {
                 final ConsumerRecords<K, V> records = consumer.poll(Duration.ofMillis(500L));
                 for (final ConsumerRecord<K, V> record : records) {
                     recordValues.add(record.value());