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.