produceMsg('{"a":"b"}'); var_dump($data); } public function testConsumer() { // KafkaService::instance()->consumeMsg(); KafkaService::instance()->consumeHigh(); } public function testGetDotUser() { $oAna = new \app\main\model\object\AnalysisObject(); $oAna->data = [ ]; $oAna->type = KafkaDotConstants::TYPE_ORDER_COMPLETE; $oAna->event_time = time(); $oAna->user_from = [ "qrcode_id" => "1" ]; \app\main\service\KafkaDotService::instance()->sendMsg(60008, $oAna); } }