An editable WME Docker Compose processor that validates and transforms Kafka telemetry.
Create a Docker Compose from GitHub processor definition using this repository and branch main. Add Kafka input and output interfaces. CONSUMER_GROUP_ID is required and must be unique for concurrently running manifests that should each receive every record.
| Parameter | Default | Purpose |
|---|---|---|
CONSUMER_GROUP_ID |
required | Kafka consumer group |
AUTO_OFFSET_RESET |
earliest |
earliest or latest |
OUTPUT_METRIC |
empty | Optional replacement metric |
VALUE_MULTIPLIER |
1 |
Numeric scale |
VALUE_OFFSET |
0 |
Numeric offset |
OUTPUT_UNIT |
empty | Optional replacement unit |
INVALID_RECORD_POLICY |
skip |
skip or fail |
Input example: {"timestamp":"2026-07-24T10:00:00Z","assetId":"pump-1","metric":"temperature","value":10,"unit":"C"}. With multiplier 1.8 and offset 32, the output value is 50.
pip install -r requirements-dev.txt
ruff check . && pytest
docker compose config && docker compose buildApache-2.0 licensed.