station-test-api/catch/api/controller/sqlLister.php

<?php
namespace catchAdmin\api\controller;

use catchAdmin\api\service\mysqlToKafuka01;
use catcher\base\CatchController;
use think\facade\Cache;

class sqlLister extends CatchController
{
    /**
     * 监听者 function
     *
     * @return void
     */
    public function lister(){
       $redis=Cache::store('redis')->handler();
       $sqlTokafuka=  new mysqlToKafuka01(2,$redis);
       
       $sqlTokafuka->sql_monitor(); 

    }













}