Pipeline: Streaming Word Count
Browser
→
Kafka: sentences
→
Flink: SPLIT → OVER(5min) → COUNT
→
Kafka: word-counts
→
Dashboard
Word Counts
Warte auf Flink...
Word Updates (Live)
Warte auf Ergebnisse...
Rolling 5-Min OVER Window
Rolling 5-Min OVER Window
Gesendete Sätze
Noch keine Sätze...
Cluster Stats
-Brokers
-
Flink Jobs
-
Sentences
-
Word Counts
-
Raw Kafka Messages
Input: sentences
Output: word-counts
Pipeline: Fraud Detection
Transaktion
→
Kafka: transactions
→
Flink: 4 Fraud Rules
→
Kafka: fraud-alerts
→
Alert Dashboard
Simulation starten:
Oder manuell:
Fraud Alerts (Live)
0 AlertsKeine Alerts...
Sende verdächtige Transaktionen um Alerts auszulösen
Sende verdächtige Transaktionen um Alerts auszulösen
Fraud Stats
Total Alerts
0
Transactions
0
Flink Jobs
-
High Value
0
Rapid Fire
0
Micro Probe
0
Large Volume
0
Transaktionen (Live)
Keine Transaktionen...
Raw Kafka Messages
Input: transactions
Output: fraud-alerts