hot fix: fix unit test failure introduced by segmentio#424

Jaeyo · Apr 6, 2020 · fae139e · fae139e
1 parent c0cc0f5
commit fae139e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/consumergroup.go b/consumergroup.go
@@ -215,7 +215,7 @@ func (config *ConsumerGroupConfig) Validate() error {
 		return errors.New(fmt.Sprintf("JoinGroupBackoff out of bounds: %d", config.JoinGroupBackoff))
 	}
 
-	if config.RetentionTime < defaultRetentionTime {
+	if config.RetentionTime < 0 && config.RetentionTime != defaultRetentionTime {
 		return errors.New(fmt.Sprintf("RetentionTime out of bounds: %d", config.RetentionTime))
 	}