diff --git a/app/utils/mq/kafka_v2.go b/app/utils/mq/kafka_v2.go
index 3ad729b..a5b8bbe 100644
--- a/app/utils/mq/kafka_v2.go
+++ b/app/utils/mq/kafka_v2.go
@@ -54,7 +54,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
 	kfconfig := &kafka.ConfigMap{
 		"bootstrap.servers":     config.GetConf().KafkaUrl,   // Kafka服务器地址
 		"group.id":              config.GetConf().KafkaGroup, // 消费者组ID
-		"auto.offset.reset":     "latest-offset",             // 自动从最早的消息开始消费
+		"auto.offset.reset":     "latest",                    // 自动从最早的消息开始消费
 		"heartbeat.interval.ms": 1000,
 		"session.timeout.ms":    45000,
 		"max.poll.interval.ms":  300000, // 5 分钟, 防止积压的时候认为掉线了