graph TB
    %% IoT Sensors
    subgraph "IoT Sensors"
        A1[Temp/Pressure/Vibration<br/>Flow/Speed/Level]
    end
    
    %% Edge Processing
    subgraph "Edge Layer"
        B1[Edge Gateway<br/>Data Validation]
        B2[MQTT Broker<br/>Protocol Convert]
    end
    
    %% Stream Processing
    subgraph "DataStreamX"
        C1[Real-time Ingestion]
        C2[Pattern Detection]
        C3[Data Enrichment]
    end
    
    %% Event Streaming
    subgraph "Kafka"
        D1[Event Topics<br/>sensor-data/alerts]
        D2[Consumer Groups]
    end
    
    %% AI Engine
    subgraph "AI Processing"
        E1[Anomaly Detection]
        E2[Predictive Maintenance]
        E3[Decision Engine]
    end
    
    %% Actions
    subgraph "Actions"
        F1{Critical?}
        F2[Emergency Stop]
        F3[Auto-Fix]
        F4[Optimization]
    end
    
    %% Notifications
    subgraph "HookPilot"
        G1[Workflow Engine]
        G2[Multi-channel<br/>Telegram/Email/Slack]
    end
    
    %% Dashboard
    subgraph "React Dashboard"
        H1[Real-time Monitor]
        H2[Analytics]
        H3[Control Panel]
    end
    
    %% Storage
    subgraph "Storage"
        I1[Time Series DB]
        I2[Event Store]
    end
    
    %% Learning Loop
    subgraph "ML Loop"
        J1[Performance Metrics]
        J2[Model Retraining]
    end
    
    %% Connections
    A1 --> B1 --> B2 --> C1
    C1 --> C2 --> C3 --> D1
    D1 --> D2 --> E1
    E1 --> E2 --> E3 --> F1
    F1 -->|Yes| F2
    F1 -->|No| F3 --> F4
    F2 --> G1
    F3 --> G1
    F4 --> G1
    G1 --> G2
    D2 --> H1 --> H2
    H3 --> F3
    C3 --> I1
    E3 --> I2
    H2 --> J1 --> J2 --> E1