Equipment Telemetry Pipeline
What it does
Ingests equipment telemetry from site gateways through a Kafka-compatible broker. It keeps every device’s current state correct regardless of the order readings arrive in, and shows it live in a web app where unregistered devices can be claimed. One docker-compose up runs the whole stack.
- Site gatewaysequipment readings
- Redpanda brokerKafka-compatible
- Consumerorder-independent updates
- Postgrescurrent state per device
- Live web appclaim new devices
Tools
TypeScript, Fastify, Zod, KafkaJS, Redpanda, Postgres 16, React, Vite, Docker