🤖 Building a Telegram bot with Apache Kafka and ksqlDB
summary
Builds a Telegram bot that reads Bradford and Leeds car‑park CSV events into Apache Kafka, enriches and reserializes them with ksqlDB (protobuf schema in Schema Registry), and serves both materialised view lookups and push and pull queries over its REST API. Demo uses a 3‑minute source API, ingests every 30s, shows alerts (example threshold 1,000 spaces) and current states (examples: 73 full, 610 empty), streams to Elasticsearch via Kafka Connect, and the bot and alerts work end‑to‑end.
AI-written summary · about
chapters (16)
- 0:00Introduction
- 3:10Demo
- 9:57Telegram
- 12:41API
- 26:11State
- 29:06State query
- 38:06Using the same data
- 39:51Kafka Connect
- 41:36How we built it
- 49:24Why use Kafka
- 49:54Streams of events
- 51:14ksqlDB
- 54:04Running ksqlDB
- 54:24Why Kafka
- 55:09Wrap up
- 56:14Questions
related talks
41mApache Kafka and ksqlDB in Action: Let’s Build a Streaming Data Pipeline!
29mApache Kafka and ksqlDB in Action : Let’s Build a Streaming Data Pipeline
49mLet’s Build a Streaming Data Pipeline!
57mTaming IoT Data: Making Sense of Sensors with SQL Streaming
01h 00mCalculating the Value of Pie: Real-Time Survey Analysis With Apache Kafka®
31mFun with Sensors
01h 03mApache Kafka Event streaming platform for .NET developers
39mKafka as a Platform: The Ecosystem from the Ground Up
