feat: kafka add field to control kafka auto commit offset.

openimsdk · Apr 28, 2024 · e92c626 · e92c626
1 parent 4d5fb97
commit e92c626
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/mq/kafka/sarama.go b/mq/kafka/sarama.go
@@ -8,10 +8,11 @@ import (
 	"github.com/openimsdk/tools/errs"
 )
 
-func BuildConsumerGroupConfig(conf *Config, initial int64) (*sarama.Config, error) {
+func BuildConsumerGroupConfig(conf *Config, initial int64, autoCommitEnable bool) (*sarama.Config, error) {
 	kfk := sarama.NewConfig()
 	kfk.Version = sarama.V2_0_0_0
 	kfk.Consumer.Offsets.Initial = initial
+	kfk.Consumer.Offsets.AutoCommit.Enable = autoCommitEnable
 	kfk.Consumer.Return.Errors = false
 	if conf.Username != "" || conf.Password != "" {
 		kfk.Net.SASL.Enable = true