Building a Telegram bot with Apache Kafka, Go, and ksqlDB.
summary
Live demo builds a Telegram bot that reads Bradford council car-park CSVs via a REST poll every 15 seconds, pipes them into Apache Kafka, enriches and reserializes to Protobuf with ksqlDB, and exposes a materialized table keyed by car-park name for quick lookups. Alerts use continuous push queries (emit changes) for thresholds like >500 or >10 spaces; on-demand checks use pull queries against the ksqlDB materialized view. Code, Go bot, and Elasticsearch dashboard run end-to-end and the demo successfully returns real values (e.g., 103 → 105 free spaces).
AI-written summary · about
chapters (7)
- 0:00Introduction to talk
- 1:48Demo of Telegram bot
- 5:37Building the data pipeline
- 8:25Stream processing with ksqlDB
- 14:41Creating materialized views
- 17:07Event-driven alerts and queries
- 18:52Summary and resources
related talks
38m🤖 Building a Telegram Bot with Apache Kafka, Go & ksqlDB
29mGo Big with Apache Kafka
34mETL on Kafka + Confluent: Problems and Solutions with Go
05mGo for Real Time Streaming Architectures
28mManaging and Scaling Real Time Data Pipelines using Go
23mImplementing Event-driven Systems with Go
16mEvent Sourcing with EventStore and Go
19mInstrumenting Go Apps With OpenTelemetry