How to implement real-time database CDC with Debezium Kafka for Laravel microservices?

/ 1. Debezium connector config (docker-compose)
debezium:
  image: debezium/connect
  environment:
    BOOTSTRAP_SERVERS: kafka:9092
    CONNECTOR_NAME: orders-cdc
    DATABASE_SERVER_NAME: orders
    TABLE_INCLUDE_LIST: orders.order

// 2. Laravel Outbox Event
class OrderPlaced 
{
    use Dispatchable, InteractsWithQueue;
    
    public function handle(KafkaConsumer $consumer)
    {
        $cdcEvent = $consumer->poll('orders.order');
        if ($cdcEvent->op === 'c') {
            Cache::put("order:{$cdcEvent->after->id}", $cdcEvent->after);
            SearchIndex::upsert($cdcEvent->after);
        }
    }
}

// 3. Horizon consumer
Horizon::addListener(CdcProcessor::class);