schocco/kafka-streams-time-based-transformation

Example implementation of a custom transformation which uses punctuations to combine wallclock time and event time in processing.

KotlinMIT