feat: consumer auto commit interval

go-god · Sep 7, 2022 · 888fbaf · 888fbaf
1 parent 467fc9a
commit 888fbaf
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/option.go b/option.go
@@ -36,7 +36,7 @@ type Options struct {
 	// no data wait second
 	NoDataWaitSec int
 
-	// ConsumerAutoCommitInterval consumer auto commit interval
+	// ConsumerAutoCommitInterval consumer auto commit interval (default: 1s)
 	ConsumerAutoCommitInterval time.Duration
 
 	// Logger logger
@@ -127,6 +127,13 @@ func WithLogger(logger Logger) Option {
 	}
 }
 
+// WithConsumerAutoCommitInterval set consumer auto commit interval.
+func WithConsumerAutoCommitInterval(interval time.Duration) Option {
+	return func(o *Options) {
+		o.ConsumerAutoCommitInterval = interval
+	}
+}
+
 // PubOption publish option
 type PubOption func(p *PublishOptions)