From d21aeda5698563007b64fdee91be0b056f5b3d64 Mon Sep 17 00:00:00 2001 From: Erik van Oosten Date: Wed, 13 Nov 2024 11:46:40 +0100 Subject: [PATCH] Use same amount of messages for all consumer benchmarks --- .../scala/zio/kafka/bench/comparison/ComparisonBenchmark.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/zio-kafka-bench/src/main/scala/zio/kafka/bench/comparison/ComparisonBenchmark.scala b/zio-kafka-bench/src/main/scala/zio/kafka/bench/comparison/ComparisonBenchmark.scala index 67a68b193..8640adf6d 100644 --- a/zio-kafka-bench/src/main/scala/zio/kafka/bench/comparison/ComparisonBenchmark.scala +++ b/zio-kafka-bench/src/main/scala/zio/kafka/bench/comparison/ComparisonBenchmark.scala @@ -21,7 +21,7 @@ trait ComparisonBenchmark extends ZioBenchmark[Env] { protected final val nrPartitions: Int = 6 protected final val topicPartitions: List[TopicPartition] = (0 until nrPartitions).map(TopicPartition(topic1, _)).toList - protected final val numberOfMessages: Int = 1000000 + protected final val numberOfMessages: Int = 50000 protected final val kvs: Iterable[(String, String)] = Iterable.tabulate(numberOfMessages)(i => (s"key$i", s"msg$i")) private val javaKafkaConsumer: ZLayer[ConsumerSettings, Throwable, LowLevelKafka] =