Maintains the latest telemetry metrics per asset in a project-scoped Redis sidecar and emits seeded WME Asset State records with active/stale state and metric attributes.
Use Docker Compose from GitHub, branch main, with Kafka input/output. CONSUMER_GROUP_ID is required and should be unique across concurrent manifests that each need all records.
Parameters: CONSUMER_GROUP_ID, AUTO_OFFSET_RESET (earliest), STATE_TTL_SECONDS (86400), STALE_AFTER_SECONDS (300), and EMIT_INTERVAL_SECONDS (10). Redis data persists in the Compose project volume; no host ports or fixed names are used.
Input: {"timestamp":"2026-07-24T10:00:00Z","assetId":"pump-1","metric":"temperature","value":42,"unit":"C"}. Output includes assetId, assetName, state, lastSeen, and an attributes.temperature object.
Development: pip install -r requirements-dev.txt && ruff check . && pytest; then docker compose config && docker compose build.
Apache-2.0 licensed.