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 ```