openapi 震坤行

server/app/Services/Kafka/KafkaService.php

@@ -84,7 +84,6 @@ class KafkaService
         $this->config['topic'] = 'zkh';
         $this->kafkaConsumerConfig = $this->getConsumerConfig($this->config);
         $consumer = new Consumer($this->kafkaConsumerConfig, function (ConsumeMessage $message) {
-
             try{
                 $consumer = $message->getConsumer();
                 $kafkaMessage = json_decode($message->getValue(),true);
@@ -93,8 +92,8 @@ class KafkaService
             }catch(\Throwable $exception){
                 $this->errLog($exception,$this->kafkaConsumerConfig->getGroupInstanceId().'_consumer');
             }
-
             $consumer->stop();
+            exit;
         });
         $consumer->start();
         $consumer->close();