book_admin/tests/KafkaTest.php

<?php
/**
 * Created by PhpStorm.
 * User: Bear
 * Date: 2020/5/6
 * Time: 下午1:52
 */

use app\main\service\KafkaService;
use app\main\constants\KafkaDotConstants;

class KafkaTest extends TestInitcps_daishu_online
{
    public function testConnect()
    {
        $data = KafkaService::instance()->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);
    }
}