Отличный пример использования KSQL с PMML/MLeap. Вот еще один пример: Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data — https://github.com/kaiwaehner/ksql-udf-deep-learning-mqtt-iot