Commit c8b9e009 authored by hangjun83's avatar hangjun83

震坤行

parent 766ee90e
......@@ -96,7 +96,6 @@ class KafkaService
$this->errLog($exception,$this->kafkaConsumerConfig->getGroupInstanceId().'_consumer');
}
$consumer->stop();
exit;
});
$consumer->start();
$consumer->close();
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment