Stream Processing with KSQLDB and REST API Queries
summary
Live demo shows creating topics for users and stocks in Confluent Cloud, spinning data‑gen connectors, and using ksqlDB REST API and persistent queries to join streams and enrich events. The workshop builds streams and KTables, runs a tumbling aggregation with a 5-minute tumbling window, and flags anomalies by threshold (100 → 200 → 500) — finding one account shifting thousands of shares in minutes. All components are preprovisioned and the queries run in real time.
AI-written summary · about
chapters (13)
- 0:00KSQLDB and stream processing
- 1:27Confluent Cloud setup
- 3:59KSQLDB app and clusters
- 5:45Topics for users and stock
- 8:18API keys and data connectors
- 10:30Real-time data simulation
- 16:37Streams and tables in KSQLDB
- 23:03Persistent queries for enrichment
- 28:50Data flow visualization
- 30:36Aggregating with KSQLDB tables
- 33:29Anomaly detection in stock
- 36:16Monitoring accounts with windows
- 40:12Resources and next steps
related talks
14mPower real-time data streams from anywhere to Cosmos DB with Confluent
44mBuilding Event-Driven APIs Workshops
01h 01mMigrating applications to serverless Apache Kafka + KSQL
28mTransforming the Financial Services Industry with Event Stream Data
01h 03mApache Kafka Event streaming platform for .NET developers
01h 11mBootiful Stream Processing!
30mEvent Streaming and the Future of Applications
21mHow Apache Kafka® Generates Value In Retail With Confluent