diff --git a/app/utils/mq/kafka_v2.go b/app/utils/mq/kafka_v2.go
index ad2d658..10bbd42 100644
--- a/app/utils/mq/kafka_v2.go
+++ b/app/utils/mq/kafka_v2.go
@@ -56,6 +56,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
 		group = config.GetConf().DidpatchKafkaGroup
 	}
 	kfconfig := &kafka.ConfigMap{
+		"api.version.request":   "true",
 		"bootstrap.servers":     config.GetConf().KafkaUrl, // Kafka服务器地址
 		"group.id":              group,                     // 消费者组ID
 		"auto.offset.reset":     "latest",                  // 自动从最早的消息开始消费earliest,latest