WIP
This library adds some utility aggregation functions to the fs2-kafka processing.
- aggregation by chunk size
- aggregation by time window (i.e. all records within a timeframe are collected and released after the specific time)
- aggregation by custom conditions by the extension the abstract class
WindowRecordsAggregatorService
Planned features
- Developer may select whether the timestamp of the Kafka record or the actual time of consumption is used for attributing the record to the time window
- Developer may select how old the message should be so that we may discard it