openapi

server/app/Services/Kafka/KafkaService.php

@@ -66,8 +66,8 @@ class KafkaService
 
             if(!empty($kafkaMessage)){
                 try{
-                    app($kafkaMessage['consumer'])->{$kafkaMessage['method']}($kafkaMessage['params']);
                     $consumer->ack($message); // 手动提交
+                    app($kafkaMessage['consumer'])->{$kafkaMessage['method']}($kafkaMessage['params']);
                 }catch(\Exception $exception){
                     $this->errLog($exception);
                 }