Using KSQLDB to monitor IoT device heartbeats

We’re developing an internal platform for our Field and Remote Service teams. The scientific instruments sold by our company transmit telemetry to the platform. A significant fraction of the devices connect using a short-polling strategy (instrument sends requests periodically, servers responds immediately).

We need to determine whether a given device is “reporting”. Our definition of “reporting” is we’ve received a request from the device within last N minutes. Different instrument families poll at different rates.

We’ve gotten this working in ksqldb, but it’s complicated. We’re still learning ksqldb and wanted to ask whether this operation is a good fit for ksqldb and tips on implemention.

This topic was automatically closed after 30 days. New replies are no longer allowed.