There was an error while loading. Please reload this page.
1 parent 8bf746c commit f176953Copy full SHA for f176953
1 file changed
pkg/kgo/config.go
@@ -551,6 +551,7 @@ func defaultCfg() cfg {
551
produceTimeout: 10 * time.Second,
552
recordRetries: math.MaxInt64, // effectively unbounded
553
maxUnknownFailures: 4,
554
+ linger: 10 * time.Millisecond,
555
partitioner: UniformBytesPartitioner(64<<10, true, true, nil),
556
txnBackoff: 20 * time.Millisecond,
557
0 commit comments