Low code stream processing
Write streaming applications using nothing more than YAML and some Python snippets. No Java development or build pipelines necessary.
streams: topic: ksml_sensordata_avro keyType: string valueType: avro:SensorData functions: print_message: type: forEach code: "print('key='+(key if isinstance(key,str) else str(key))+', value='+(value if isinstance(value,str) else str(value)))" pipelines: main: from: ksml_sensordata_avro forEach: print_message
Easy syntax: what you see is what you stream
The flow of messages is easily read and modified. Inserting operations takes no more than 10 seconds, and your new app runs in under 20.
libraries at your fingertips
KSML definitions allow Python libraries to be imported, providing a wealth of existing code to be reused in streaming apps.