Kafka window functions

Services for aggregating Kafka records into batches based on some criterias, such as:

time windows: records between tStart and tEnd are grouped into batch
aggregating by user-defined criterias (TBD...)