fix offset commit bug (segmentio#424)

Co-authored-by: liuzhiqing <liuzhiqing@taou.com>
Jaeyo · Apr 6, 2020 · c0cc0f5 · c0cc0f5
1 parent efce7b6
commit c0cc0f5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/consumergroup.go b/consumergroup.go
@@ -50,7 +50,7 @@ const (
 
 	// defaultRetentionTime holds the length of time a the consumer group will be
 	// saved by kafka.  This value tells the broker to use its configured value.
-	defaultRetentionTime = -1
+	defaultRetentionTime = -1 * time.Millisecond
 
 	// defaultPartitionWatchTime contains the amount of time the kafka-go will wait to
 	// query the brokers looking for partition changes.