additional

Author: Matt Howlett

test/Confluent.Kafka.Benchmark/BenchmarkProducer.cs

@@ -55,7 +55,8 @@ private static long BenchmarkProducerImpl(string bootstrapServers, string topic,
                 { "bootstrap.servers", bootstrapServers },
                 { "queue.buffering.max.messages", 2000000 },
                 { "message.send.max.retries", 3 },
-                { "retry.backoff.ms", 500 }
+                { "retry.backoff.ms", 500 },
+                { "linger.ms", 100 }
             };
 
             Message firstDeliveryReport = null;