Stream Processing Fundamentals
ksqlDB UDFs and UDAFs Made Easy | Confluent

ksqlDB UDFs and UDAFs Made Easy | Confluent

8/6/2019 · Mitch Seymour

What this post added

Introduces a new Maven archetype (`ksql-udf-quickstart` or `ksqldb-udf-quickstart` for newer versions) to simplify the creation and bootstrapping of ksqlDB User-Defined Functions (UDFs) and User-Defined Aggregate Functions (UDAFs). The archetype generates a project structure with example UDF (REVERSE) and UDAF (SUMMARY_STATS) implementations, demonstrating how to define functions, handle multiple data types, and implement aggregation logic (initialize, aggregate, merge). It also provides instructions for setting up Maven repositories and building the project into an uber JAR for deployment to a ksqlDB server. The post also covers converting the generated Maven project to a Gradle project.

Read the original post ↗