Exactly! With Node-RED flow, which is publishing to MQTT, we wanted to simulate a generic data source, e.g., modern PLCs, which can already publish via MQTT but still need a data contextualization step. So, MQTT from PLCs as raw data -> Benthos to convert to Kafka and contextualize -> from there on the Kafka pipeline via the data contracts. Hope that helps!