station-test-api/catch/api/service/mysqlToKafuka.php

<?php
namespace catchAdmin\api\service;

use think\facade\Db;

//脚本衢州 从mysql中存到kafka/redis中
class mysqlToKafuka
{
    //mysql 监听器

    public function sql_monitor(){
        $table="test";
        $list=Db::name($table)->where("status",1)->select();
        foreach($list as $key=>$item){
            $table_name=$item["table_name"];
            $type=$item["type"];
            $table_id=$item["table_id"];
        }

    }
    /**
     * 业务处理
     *
     * @param [type] $table_name
     * @param [type] $table_id
     * @param [type] $type
     * @return void
     */
    public function Operation($table_name,$table_id,$type){
        switch($table_name)
        {
           case "fjd_zcdj":




        }
        


    }

    public function toKafuka($data){
        




    }
    public function toRedis($data){

    }


















}