Hello there!
The actual "bug" seems to be your config key. You used benthosConfig as a text block, but umh-core does not recognize that key, so it silently fell back to an empty config, and Benthos then failed on the empty result.
The correct key is dataFlowComponentConfig, with benthos nested inside as normal YAML, not as a text block.
yaml
dataFlow:
- name: webhook-receiver
desiredState: active
dataFlowComponentConfig:
benthos:
input:
http_server:
address: 0.0.0.0:8080
path: /api/data
timeout: 5s
pipeline:
processors:
- mapping: |
root.timestamp = now()
root.machine = this.machine
root.temperature = this.temperature
output:
kafka:
addresses:
- localhost:9092
topic: umh.v1.be.marke._raw.machine_data
Try this and let us know if it deploys :).