make consumer benchmark 5x faster (#998)

confluentinc · Jun 28, 2019 · 1c05a0f · 1c05a0f
1 parent 88813ff
commit 1c05a0f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/test/Confluent.Kafka.Benchmark/BenchmarkConsumer.cs b/test/Confluent.Kafka.Benchmark/BenchmarkConsumer.cs
@@ -30,7 +30,8 @@ public static void BenchmarkConsumerImpl(string bootstrapServers, string topic,
                 GroupId = "benchmark-consumer-group",
                 BootstrapServers = bootstrapServers,
                 SessionTimeoutMs = 6000,
-                ConsumeResultFields = nHeaders == 0 ? "none" : "headers"
+                ConsumeResultFields = nHeaders == 0 ? "none" : "headers",
+                QueuedMinMessages = 1000000
             };
 
             using (var consumer = new ConsumerBuilder<Ignore, Ignore>(consumerConfig).Build())