-
Notifications
You must be signed in to change notification settings - Fork 2
Open
Description
The new feature, ConsumePreferringLagFn, allows you to have some advanced reordering of how to consume. The recommended way of using this option is kgo.ConsumePreferringLagFn(kgo.PreferLagAt(50)), which allows you to favor laggy partitions if the client is more than 50 records behind in the topic.
Metadata
Metadata
Assignees
Labels
No labels