flowchart TB
    subgraph SRC["Source Domains"]
        S1["OLTP systems"]
        S2["SaaS APIs"]
        S3["IoT / telemetry"]
        S4["Files / batch feeds"]
    end

    subgraph INGEST["Ingestion Zone"]
        CDC["CDC — Debezium"]
        API["API / webhook gateway"]
        GW["Contract validation<br/>+ Schema Registry"]
        CANON["Canonicalizer"]
        ER["Entity Resolution service"]
        CLS["Classifier / policy tagger"]
        QT[("Quarantine")]
    end

    subgraph LOG["Event Backbone"]
        K1[["canonical.* topics<br/>entity-key partitioned"]]
        K2[["correlations.*"]]
        K3[["insights.*"]]
        K4[["lineage.*"]]
    end

    subgraph STREAM["Stream Compute"]
        F1["Flink — M1 temporal"]
        F2["Flink — M2 entity"]
        F4["Flink — M4 semantic"]
        F5["Flink — M5 behavioural"]
        RE["Rules engine"]
        SS[("RocksDB state<br/>+ checkpoints")]
    end

    subgraph BATCH["Batch / Lakehouse"]
        BZ[("Bronze")]
        SZ[("Silver")]
        GZ[("Gold")]
        SPK["Spark — W1..W4<br/>wide window, M3 causal,<br/>graph algorithms,<br/>re-correlation"]
    end

    subgraph SERVE["Serving"]
        GH[("Graph hot tier")]
        GC[("Graph cold tier")]
        VDB[("Vector index")]
        FS[("Feature store")]
        API2["Insight API / GraphQL"]
    end

    subgraph INTEL["Insight Layer"]
        ML["Model serving"]
        LLM["Grounded generation<br/>+ citation validation"]
        AC["Autonomy Controller"]
    end

    subgraph PLANE["Cross-Cutting Planes"]
        MD[("Metadata + lineage")]
        OPA["Policy engine"]
        OBS["Observability"]
    end

    SRC --> CDC & API
    CDC & API --> GW --> CANON --> ER --> CLS --> K1
    CLS -.->|reject| QT
    K1 --> F1 & F2 & F4 & F5 & RE
    F1 & F2 & F4 & F5 --> SS
    F1 & F2 & F4 & F5 & RE --> K2
    K1 --> BZ --> SZ --> GZ
    K2 --> SZ
    SPK --> GZ
    GZ --> SPK
    SPK -->|"reconciliation"| K2
    K2 --> GH --> GC
    K1 --> VDB
    GZ --> FS
    GH & VDB & FS --> ML --> LLM --> AC --> K3
    GH & K2 --> API2
    K3 --> API2
    PLANE -.-> INGEST & STREAM & BATCH & SERVE & INTEL
    INGEST & STREAM & BATCH & INTEL -.-> K4 --> MD

    classDef src fill:#123043,stroke:#2c7ea8,color:#dceefc
    classDef ing fill:#0d4159,stroke:#22b3d6,color:#eaf9ff
    classDef log fill:#0a5570,stroke:#3fd0f0,stroke-width:2px,color:#ffffff
    classDef str fill:#183028,stroke:#4caf7d,color:#e6fff2
    classDef bat fill:#2a2440,stroke:#7a6fd6,color:#eee9ff
    classDef srv fill:#3a2f1a,stroke:#c9a227,color:#fff6dc
    classDef int fill:#3d1f28,stroke:#d64550,color:#ffe8ec
    classDef pl fill:#1a2a33,stroke:#4d8296,color:#d8eef7
    class S1,S2,S3,S4 src
    class CDC,API,GW,CANON,ER,CLS,QT ing
    class K1,K2,K3,K4 log
    class F1,F2,F4,F5,RE,SS str
    class BZ,SZ,GZ,SPK bat
    class GH,GC,VDB,FS,API2 srv
    class ML,LLM,AC int
    class MD,OPA,OBS pl