Skip to content

Commit

Permalink
Use same amount of messages for all consumer benchmarks
Browse files Browse the repository at this point in the history
  • Loading branch information
erikvanoosten committed Nov 13, 2024
1 parent 504074f commit 2cd592d
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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] =
Expand Down

0 comments on commit 2cd592d

Please sign in to comment.