IoT Fleet Management Data Streaming
Building a Telegram Bot Powered by Kafka and ksqlDB

Building a Telegram Bot Powered by Kafka and ksqlDB

5/12/2020 · Robin Moffatt

What this post added

This post details building a Telegram bot powered by Kafka and ksqlDB. It demonstrates how to ingest Wi-Fi packet data into Kafka, process it with ksqlDB to create stateful aggregates (tables), and then query these aggregates using pull queries to serve on-demand information to a Telegram bot. The technical depth includes ksqlDB schema declaration, table creation with aggregations (COUNT, MIN, MAX, COLLECT_SET), and the use of interactive queries (via REST API) to access the materialized state. It also touches upon the underlying storage mechanisms of ksqlDB (Kafka changelog, RocksDB) and the concept of events as the primary system of record.

Read the original post ↗