Specify max to throttle argument

Aiven-Open · Sep 16, 2022 · 627b64b · 627b64b
1 parent 0ce62b1
commit 627b64b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core-s3/src/test/scala/io/aiven/guardian/kafka/s3/S3Spec.scala b/core-s3/src/test/scala/io/aiven/guardian/kafka/s3/S3Spec.scala
@@ -199,7 +199,7 @@ trait S3Spec
   ): Source[ProducerRecord[Array[Byte], Array[Byte]], NotUsed] = {
     val durationToMicros = streamDuration.toMillis
     val topicsPerMillis  = producerRecords.size / durationToMicros
-    Source(producerRecords).throttle(topicsPerMillis.toInt, 1 millis)
+    Source(producerRecords).throttle(topicsPerMillis.toInt max 1, 1 millis)
   }
 
   /** Converts a generated list of `ReducedConsumerRecord` to a list of `ProducerRecord`