Update OutboxProcessorIntegrationTest.java

Author: magro

outbox-kafka-spring-reactive/src/test/java/one/tomorrow/transactionaloutbox/reactive/service/OutboxProcessorIntegrationTest.java

@@ -146,7 +146,7 @@ void should_processRecordsInOrder_whenKafkaIsTemporarilyNotAvailable() {
         testee = new OutboxProcessor(repository, lockService, producerFactory(producerProps), processingInterval, DEFAULT_OUTBOX_LOCK_TIMEOUT, "processor", eventSource, batchSize);
 
         // when
-        int numRecords = 50000;
+        int numRecords = 5000;
         List<Mono<OutboxRecord>> outboxRecordMonos = IntStream.rangeClosed(1, numRecords).mapToObj(i -> {
             // - use the same key so that even if the kafka setup / number of partitions is changed the events still are on the same partition
             // - The Mono has to be cached, so that it can be consumed twice
@@ -161,7 +161,7 @@ void should_processRecordsInOrder_whenKafkaIsTemporarilyNotAvailable() {
 
         // then
         List<OutboxRecord> outboxRecords = getSortedById(outboxRecordMonos);
-        Iterator<ConsumerRecord<String, byte[]>> kafkaRecordsIter = consumeAndDeduplicateRecords(outboxRecords.size(), Duration.ofSeconds(30))
+        Iterator<ConsumerRecord<String, byte[]>> kafkaRecordsIter = consumeAndDeduplicateRecords(outboxRecords.size(), Duration.ofSeconds(300))
                 .iterator();
         for (OutboxRecord outboxRecord : outboxRecords) {
             assertConsumedRecord(outboxRecord, eventSource, kafkaRecordsIter.next());