ReaderConfig.RetentionTime usage (segmentio#341)

Using RetentionTime from ReaderConfig on create NewConsumerGroup
ravi4422 · Aug 26, 2019 · 531c50b · 531c50b
1 parent 8724c87
commit 531c50b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/reader.go b/reader.go
@@ -635,6 +635,7 @@ func NewReader(config ReaderConfig) *Reader {
 			SessionTimeout:         r.config.SessionTimeout,
 			RebalanceTimeout:       r.config.RebalanceTimeout,
 			JoinGroupBackoff:       r.config.JoinGroupBackoff,
+			RetentionTime:          r.config.RetentionTime,
 			StartOffset:            r.config.StartOffset,
 			Logger:                 r.config.Logger,
 			ErrorLogger:            r.config.ErrorLogger,