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

openimsdk · Apr 28, 2024 · 38d5a6f · 38d5a6f
1 parent e92c626
commit 38d5a6f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/mq/kafka/consumer_group.go b/mq/kafka/consumer_group.go
@@ -28,8 +28,8 @@ type MConsumerGroup struct {
 	topics  []string
 }
 
-func NewMConsumerGroup(conf *Config, groupID string, topics []string) (*MConsumerGroup, error) {
-	config, err := BuildConsumerGroupConfig(conf, sarama.OffsetNewest)
+func NewMConsumerGroup(conf *Config, groupID string, topics []string, autoCommitEnable bool) (*MConsumerGroup, error) {
+	config, err := BuildConsumerGroupConfig(conf, sarama.OffsetNewest, autoCommitEnable)
 	if err != nil {
 		return nil, err
 	}

diff --git a/mq/kafka/verify.go b/mq/kafka/verify.go
@@ -22,7 +22,7 @@ import (
 )
 
 func Check(ctx context.Context, conf *Config, topics []string) error {
-	kfk, err := BuildConsumerGroupConfig(conf, sarama.OffsetNewest)
+	kfk, err := BuildConsumerGroupConfig(conf, sarama.OffsetNewest, false)
 	if err != nil {
 		return err
 	}