Skip to content

Commit f176953

Browse files
committed
kgo lingering: default to 10ms
Closes #1072.
1 parent 8bf746c commit f176953

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

‎pkg/kgo/config.go‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -551,6 +551,7 @@ func defaultCfg() cfg {
551551
produceTimeout: 10 * time.Second,
552552
recordRetries: math.MaxInt64, // effectively unbounded
553553
maxUnknownFailures: 4,
554+
linger: 10 * time.Millisecond,
554555
partitioner: UniformBytesPartitioner(64<<10, true, true, nil),
555556
txnBackoff: 20 * time.Millisecond,
556557

0 commit comments

Comments
 (0)