Maize Telemetry Generator

Public GitHub Compose processor for the MODUL4R Workflow Management Editor. It continuously publishes realistic Telemetry Event JSON records to the Kafka Digital Resource selected as the manifest output.

WME contract

• Deployment: GitHub Compose, repository root
• Input: none
• Output: Kafka using KAFKA_BOOTSTRAP_SERVERS_OUTPUT and KAFKA_TOPIC_ID_OUTPUT
• Runtime: long-running until stopped by WME; MAX_EVENTS=0 means unlimited

Example record:

{"eventTime":"2026-07-24T10:30:00+00:00","assetId":"machine-01","assetName":"Demo machine","metric":"temperature","value":72.4,"unit":"celsius","anomaly":false}

Manifest parameters are ASSET_ID, ASSET_NAME, METRIC, UNIT, MIN_VALUE, MAX_VALUE, INTERVAL_SECONDS, ANOMALY_RATE, RANDOM_SEED, and MAX_EVENTS.

Development

python -m venv .venv
. .venv/bin/activate
pip install -r requirements-dev.txt
ruff check src tests
pytest
docker compose config
docker compose build

Connection credentials are supplied by WME at runtime and must never be committed.