diff --git a/README.md b/README.md
index e11f43a..a93ad72 100644
--- a/README.md
+++ b/README.md
@@ -27,7 +27,6 @@ graph TB
ES[Event Simulator
Kafka Producer]
K[Apache Kafka
KRaft Mode]
FP[Flink Stream Processor
Flink 2.0.2]
- MA[MetricAggregator
30s Tumbling Windows]
AD[AnomalyDetector
Thresholds + EMA Baseline]
end
@@ -53,7 +52,6 @@ graph TB
ES -->|Protobuf| K
K --> FP
- FP --> MA
FP --> AD
AD -->|Alerts| K
FP -.->|Metrics| PROM
@@ -133,8 +131,6 @@ flowchart LR
subgraph "Stream Processing"
KT[Kafka Topic
stream-events]
DESER[StreamEventDeserializer
Protobuf]
- SPLIT{Event Type?}
- AGG[MetricAggregator
30s Windows]
DET[AnomalyDetector
Keyed State]
ALERT[Kafka Topic
stream-alerts]
end
@@ -143,9 +139,7 @@ flowchart LR
SR --> SIM
MG & LG & HG -->|Protobuf| KT
KT --> DESER
- DESER --> SPLIT
- SPLIT -->|Metric| AGG
- SPLIT -->|All| DET
+ DESER --> DET
DET -->|Threshold breach| ALERT
```