diff --git a/mq/kafka/sarama.go b/mq/kafka/sarama.go
index 95a2b5a..23220b4 100644
--- 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