Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 1 addition & 7 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,6 @@ graph TB
ES[Event Simulator<br/>Kafka Producer]
K[Apache Kafka<br/>KRaft Mode]
FP[Flink Stream Processor<br/>Flink 2.0.2]
MA[MetricAggregator<br/>30s Tumbling Windows]
AD[AnomalyDetector<br/>Thresholds + EMA Baseline]
end

Expand All @@ -53,7 +52,6 @@ graph TB

ES -->|Protobuf| K
K --> FP
FP --> MA
FP --> AD
AD -->|Alerts| K
FP -.->|Metrics| PROM
Expand Down Expand Up @@ -133,8 +131,6 @@ flowchart LR
subgraph "Stream Processing"
KT[Kafka Topic<br/>stream-events]
DESER[StreamEventDeserializer<br/>Protobuf]
SPLIT{Event Type?}
AGG[MetricAggregator<br/>30s Windows]
DET[AnomalyDetector<br/>Keyed State]
ALERT[Kafka Topic<br/>stream-alerts]
end
Expand All @@ -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
```

Expand Down
Loading