Extensions

Kuiper allows user to customize the different kinds of extensions.

The source extension is used for extending different stream source, such as consuming data from other message brokers. Kuiper has built-in source support for MQTT broker.
Sink/Action extension is used for extending pub/push data to different targets, such as database, other message system, web interfaces or file systems. Built-in action support in Kuiper, see MQTT & log files.
Functions extension allows user to extend different functions that used in SQL. Built-in functions supported in Kuiper, see functions.

Please read below for how to realize the different extensions.