In Fluvio, data modification is done using SmartModules, user-defined functions converted to WebAssembly (WASM). Several SmartModules can form a Transformation Chain, working in sequence—each one modifies the data and passes it to the next. Both the sending (Producer) and receiving (Consumer) ends can use these chains; for the Producer, modification happens before the data is saved to the topic, while for the Consumer, it occurs before sending the data.
Transformation Chaining is available for:
Setting It Up
Each transformation in the chain is a SmartModule, paired with some specific instructions. Typically, you’d set this up in a yaml file.