We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1b64d17 commit b2b17acCopy full SHA for b2b17ac
reader.go
@@ -469,9 +469,11 @@ type ReaderConfig struct {
469
JoinGroupBackoff time.Duration
470
471
// RetentionTime optionally sets the length of time the consumer group will be saved
472
- // by the broker
+ // by the broker. -1 will disable the setting and leave the
473
+ // retention up to the broker's offsets.retention.minutes property. By
474
+ // default, that setting is 1 day for kafka < 2.0 and 7 days for kafka >= 2.0.
475
//
- // Default: 24h
476
+ // Default: -1
477
478
// Only used when GroupID is set
479
RetentionTime time.Duration
0 commit comments