KSML:
Kafka Streams for Low Code Environments
KSML is...
Low code stream processing
Write streaming applications using nothing more than YAML and some Python snippets. No Java development or build pipelines necessary.
streams:
ksml_sensordata_avro:
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.
Python function
libraries at your fingertips
KSML definitions allow Python libraries to be imported, providing a wealth of existing code to be reused in streaming apps.
Create your first KSML app in minutes